@Experimental(value=SOURCE_SINK)
See: Description
Interface | Description |
---|---|
ElasticsearchIO.Write.BooleanFieldValueExtractFn | |
ElasticsearchIO.Write.FieldValueExtractFn |
Interface allowing a specific field value to be returned from a parsed JSON document.
|
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. |