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

package org.apache.beam.sdk.io.elasticsearch

Common test utilities for Elasticsearch.

Related Packages

Package	Description
org.apache.beam.sdk.io	Defines transforms for reading and writing common storage formats, including invalid reference org.apache.beam.sdk.io.AvroIO , and TextIO.

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