Packages

object ElasticsearchSource

Scala API to create Elasticsearch sources.

Source
ElasticsearchSource.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ElasticsearchSource
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def apply(elasticsearchParams: ElasticsearchParams, searchParams: Map[String, String], settings: SourceSettingsBase[_, _]): Source[ReadResult[JsObject], NotUsed]

    Creates a pekko.stream.scaladsl.Source from Elasticsearch that streams ReadResults of Spray's spray.json.JsObject.

    Creates a pekko.stream.scaladsl.Source from Elasticsearch that streams ReadResults of Spray's spray.json.JsObject. Alias of create.

    Example of searchParams-usage: Map( "query" -> """{"match_all": {}}""" ) Map( "query" -> """{"match_all": {}}""", "_source" -> """ ["fieldToInclude", "anotherFieldToInclude"] """ )

  2. def apply(elasticsearchParams: ElasticsearchParams, query: String, settings: SourceSettingsBase[_, _]): Source[ReadResult[JsObject], NotUsed]

    Creates a pekko.stream.scaladsl.Source from Elasticsearch that streams ReadResults of Spray's spray.json.JsObject.

    Creates a pekko.stream.scaladsl.Source from Elasticsearch that streams ReadResults of Spray's spray.json.JsObject. Alias of create.

  3. def create(elasticsearchParams: ElasticsearchParams, searchParams: Map[String, String], settings: SourceSettingsBase[_, _]): Source[ReadResult[JsObject], NotUsed]

    Creates a pekko.stream.scaladsl.Source from Elasticsearch that streams ReadResults of Spray's spray.json.JsObject.

    Creates a pekko.stream.scaladsl.Source from Elasticsearch that streams ReadResults of Spray's spray.json.JsObject.

    Example of searchParams-usage: Map( "query" -> """{"match_all": {}}""" ) Map( "query" -> """{"match_all": {}}""", "_source" -> """ ["fieldToInclude", "anotherFieldToInclude"] """ )

  4. def create(elasticsearchParams: ElasticsearchParams, query: String, settings: SourceSettingsBase[_, _]): Source[ReadResult[JsObject], NotUsed]

    Creates a pekko.stream.scaladsl.Source from Elasticsearch that streams ReadResults of Spray's spray.json.JsObject.

  5. def typed[T](elasticsearchParams: ElasticsearchParams, searchParams: Map[String, String], settings: SourceSettingsBase[_, _])(implicit sprayJsonReader: JsonReader[T]): Source[ReadResult[T], NotUsed]

    Creates a pekko.stream.scaladsl.Source from Elasticsearch that streams ReadResults of type T converted by Spray's spray.json.JsonReader

    Creates a pekko.stream.scaladsl.Source from Elasticsearch that streams ReadResults of type T converted by Spray's spray.json.JsonReader

    Example of searchParams-usage: Map( "query" -> """{"match_all": {}}""" ) Map( "query" -> """{"match_all": {}}""", "_source" -> """ ["fieldToInclude", "anotherFieldToInclude"] """ )

  6. def typed[T](elasticsearchParams: ElasticsearchParams, query: String, settings: SourceSettingsBase[_, _])(implicit sprayJsonReader: JsonReader[T]): Source[ReadResult[T], NotUsed]

    Creates a pekko.stream.scaladsl.Source from Elasticsearch that streams ReadResults of type T converted by Spray's spray.json.JsonReader