Interface | Description |
---|---|
ActionRequestFailureHandler | Deprecated
This has been deprecated and will be removed in the future.
|
ElasticsearchApiCallBridge<C extends AutoCloseable> |
An
ElasticsearchApiCallBridge is used to bridge incompatible Elasticsearch Java API calls
across different versions. |
ElasticsearchSinkFunction<T> | Deprecated
This has been deprecated and will be removed in the future.
|
RequestIndexer | Deprecated
This has been deprecated and will be removed in the future.
|
Class | Description |
---|---|
ElasticsearchSinkBase<T,C extends AutoCloseable> |
Base class for all Flink Elasticsearch Sinks.
|
ElasticsearchSinkBase.BulkFlushBackoffPolicy |
Provides a backoff policy for bulk requests.
|
Enum | Description |
---|---|
ElasticsearchSinkBase.FlushBackoffType |
Used to control whether the retry delay should increase exponentially or remain constant.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.