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
Provides a backoff policy for bulk requests.
|
ElasticsearchSinkBase.FlushBackoffType
Used to control whether the retry delay should increase exponentially or remain constant.
|
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
Provides a backoff policy for bulk requests.
|
Class and Description |
---|
ElasticsearchApiCallBridge
An
ElasticsearchApiCallBridge is used to bridge incompatible Elasticsearch Java API calls across different versions. |
ElasticsearchSinkBase.BulkFlushBackoffPolicy
Provides a backoff policy for bulk requests.
|
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.