Package org.apache.flink.streaming.connectors.elasticsearch

Interface Summary

Interface	Description
ActionRequestFailureHandler	An implementation of ActionRequestFailureHandler is provided by the user to define how failed ActionRequests should be handled, e.g.
ElasticsearchApiCallBridge	An ElasticsearchApiCallBridge is used to bridge incompatible Elasticsearch Java API calls across different versions.
ElasticsearchSinkFunction<T>	Creates multiple ActionRequests from an element in a stream.
IndexRequestBuilder<T>	Deprecated Deprecated since version 1.2, to be removed at version 2.0.
RequestIndexer	Users add multiple ActionRequests to a RequestIndexer to prepare them for sending to an Elasticsearch cluster.

Class Summary

Class	Description
Elasticsearch1ApiCallBridge	Implementation of ElasticsearchApiCallBridge for Elasticsearch 1.x.
ElasticsearchSink<T>	Elasticsearch 1.x sink that requests multiple ActionRequests against a cluster for each incoming element.
ElasticsearchSinkBase<T>	Base class for all Flink Elasticsearch Sinks.
ElasticsearchSinkBase.BulkFlushBackoffPolicy	Provides a backoff policy for bulk requests.

Enum Summary

Enum	Description
ElasticsearchSinkBase.FlushBackoffType	Used to control whether the retry delay should increase exponentially or remain constant.