package elasticsearch
Main package for Elasticsearch APIs. Import all.
import com.spotify.scio.elasticsearch._
- Source
- package.scala
- Alphabetic
- By Inheritance
- elasticsearch
- CoderInstances
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- trait CoderInstances extends AnyRef
- final case class ElasticsearchIO[T](esOptions: ElasticsearchOptions) extends ScioIO[T] with Product with Serializable
- final case class ElasticsearchOptions(nodes: Seq[HttpHost], usernameAndPassword: Option[(String, String)] = None, mapperFactory: () => JsonpMapper = defaultMapper) extends Product with Serializable
- implicit final class ElasticsearchSCollection[T] extends AnyVal
Value Members
- implicit val bulkOperationCoder: Coder[BulkOperation]
- Definition Classes
- CoderInstances
- def defaultMapper(): JsonpMapper
- object ElasticsearchIO extends Serializable
- object IndexAdmin