Class and 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. |
ElasticsearchSinkBase
Base class for all Flink Elasticsearch Sinks.
|
ElasticsearchSinkBase.BulkFlushBackoffPolicy |
ElasticsearchSinkBase.FlushBackoffType |
ElasticsearchSinkFunction
Creates multiple
ActionRequests from an element in a stream. |
IndexRequestBuilder
Deprecated.
Deprecated since version 1.2, to be removed at version 2.0.
Please create a
ElasticsearchSink using a ElasticsearchSinkFunction instead. |
RequestIndexer
Users add multiple
ActionRequests to a RequestIndexer to prepare
them for sending to an Elasticsearch cluster. |
Class and Description |
---|
ActionRequestFailureHandler
An implementation of
ActionRequestFailureHandler is provided by the user to define how failed
ActionRequests should be handled, e.g. |
RequestIndexer
Users add multiple
ActionRequests to a RequestIndexer to prepare
them for sending to an Elasticsearch cluster. |
Class and Description |
---|
ElasticsearchApiCallBridge
An
ElasticsearchApiCallBridge is used to bridge incompatible Elasticsearch Java API calls across different versions. |
ElasticsearchSinkBase.BulkFlushBackoffPolicy |
Class and Description |
---|
ElasticsearchApiCallBridge
An
ElasticsearchApiCallBridge is used to bridge incompatible Elasticsearch Java API calls across different versions. |
ElasticsearchSinkBase.BulkFlushBackoffPolicy |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.