@Experimental(value=SOURCE_SINK)

Package org.apache.beam.sdk.io.elasticsearch

Transforms for reading and writing from Elasticsearch.

See: Description

Interface Summary

Interface	Description
ElasticsearchIO.Write.FieldValueExtractFn	Interface allowing a specific field value to be returned from a parsed JSON document.

Class Summary

Class	Description
ElasticsearchIO	Transforms for reading and writing data from/to Elasticsearch.
ElasticsearchIO.BoundedElasticsearchSource	A BoundedSource reading from Elasticsearch.
ElasticsearchIO.ConnectionConfiguration	A POJO describing a connection configuration to Elasticsearch.
ElasticsearchIO.Read	A PTransform reading data from Elasticsearch.
ElasticsearchIO.RetryConfiguration	A POJO encapsulating a configuration for retry behavior when issuing requests to ES.
ElasticsearchIO.Write	A PTransform writing data to Elasticsearch.

Package org.apache.beam.sdk.io.elasticsearch Description

Transforms for reading and writing from Elasticsearch.