@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.BooleanFieldValueExtractFn
ElasticsearchIO.Write.FieldValueExtractFn

Class Summary

Class	Description
ElasticsearchIO	Transforms for reading and writing data from/to Elasticsearch.
ElasticsearchIO.BoundedElasticsearchSource	A BoundedSource reading from Elasticsearch.
ElasticsearchIO.BulkIO	A PTransform writing Bulk API entities created by ElasticsearchIO.DocToBulk to an Elasticsearch cluster.
ElasticsearchIO.ConnectionConfiguration	A POJO describing a connection configuration to Elasticsearch.
ElasticsearchIO.DocToBulk	A PTransform converting docs to their Bulk API counterparts.
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.