object ElasticsearchSource
- Alphabetic
- By Inheritance
- ElasticsearchSource
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- 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\"]");
- 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
- 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
- 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 objectMapperExample of searchParams-usage:
Map<String, String> searchParams = new HashMap<>(); searchParams.put("query", "{\"match_all\": {}}"); searchParams.put("_source", "[\"fieldToInclude\", \"anotherFieldToInclude\"]");
- 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 - 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