See: Description
| Interface | Description |
|---|---|
| ElasticsearchIO.Write.BooleanFieldValueExtractFn | |
| ElasticsearchIO.Write.FieldValueExtractFn | |
| ElasticsearchIOITCommon.ElasticsearchPipelineOptions |
Pipeline options for elasticsearch tests.
|
| 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.Document | |
| ElasticsearchIO.DocumentCoder | |
| 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. |
| ElasticsearchIOITCommon |
Manipulates test data used by the
ElasticsearchIO integration tests. |