Packages

object ElasticsearchSource

Java API to create Elasticsearch sources.

Source
ElasticsearchSource.scala
Linear Supertypes
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 create(elasticsearchParams: ElasticsearchParams, searchParams: Map[String, String], settings: SourceSettingsBase[_, _], objectMapper: ObjectMapper): Source[ReadResult[Map[String, AnyRef]], NotUsed]

    Creates a pekko.stream.javadsl.Source from Elasticsearch that streams ReadResults of java.util.Map.

    Creates a pekko.stream.javadsl.Source from Elasticsearch that streams ReadResults of java.util.Map. Using custom objectMapper.

    Example of searchParams-usage:

    Map<String, String> searchParams = new HashMap<>(); searchParams.put("query", "{\"match_all\": {}}"); searchParams.put("_source", "[\"fieldToInclude\", \"anotherFieldToInclude\"]");

  2. def create(elasticsearchParams: ElasticsearchParams, query: String, settings: SourceSettingsBase[_, _], objectMapper: ObjectMapper): Source[ReadResult[Map[String, AnyRef]], NotUsed]

    Creates a pekko.stream.javadsl.Source from Elasticsearch that streams ReadResults of java.util.Map.

    Creates a pekko.stream.javadsl.Source from Elasticsearch that streams ReadResults of java.util.Map. Using custom objectMapper

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

    Creates a pekko.stream.javadsl.Source from Elasticsearch that streams ReadResults of java.util.Map.

    Creates a pekko.stream.javadsl.Source from Elasticsearch that streams ReadResults of java.util.Map. Using default objectMapper

  4. def typed[T](elasticsearchParams: ElasticsearchParams, searchParams: Map[String, String], settings: SourceSettingsBase[_, _], clazz: Class[T], objectMapper: ObjectMapper): Source[ReadResult[T], NotUsed]

    Creates a pekko.stream.javadsl.Source from Elasticsearch that streams ReadResults of type T.

    Creates a pekko.stream.javadsl.Source from Elasticsearch that streams ReadResults of type T. Using custom objectMapper

    Example of searchParams-usage:

    Map<String, String> searchParams = new HashMap<>(); searchParams.put("query", "{\"match_all\": {}}"); searchParams.put("_source", "[\"fieldToInclude\", \"anotherFieldToInclude\"]");

  5. def typed[T](elasticsearchParams: ElasticsearchParams, query: String, settings: SourceSettingsBase[_, _], clazz: Class[T], objectMapper: ObjectMapper): Source[ReadResult[T], NotUsed]

    Creates a pekko.stream.javadsl.Source from Elasticsearch that streams ReadResults of type T.

    Creates a pekko.stream.javadsl.Source from Elasticsearch that streams ReadResults of type T. Using custom objectMapper

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

    Creates a pekko.stream.javadsl.Source from Elasticsearch that streams ReadResults of type T.

    Creates a pekko.stream.javadsl.Source from Elasticsearch that streams ReadResults of type T. Using default objectMapper