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.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. |
ElasticsearchUpsertTableSinkBase
A version-agnostic Elasticsearch
UpsertStreamTableSink . |
ElasticsearchUpsertTableSinkBase.ElasticsearchUpsertSinkFunction
Sink function for converting upserts into Elasticsearch
ActionRequest s. |
ElasticsearchUpsertTableSinkBase.Host
Entity for describing a host of Elasticsearch.
|
ElasticsearchUpsertTableSinkBase.RequestFactory
For version-agnostic creating of
ActionRequest s. |
ElasticsearchUpsertTableSinkBase.SinkOption
Keys for optional parameterization of the sink.
|
RequestIndexer
Users add multiple delete, index or update requests 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 delete, index or update requests 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. |
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.
|
ElasticsearchSinkFunction
Creates multiple
ActionRequests from an element in a stream. |
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 |
---|
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.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. |
ElasticsearchUpsertTableSinkBase
A version-agnostic Elasticsearch
UpsertStreamTableSink . |
ElasticsearchUpsertTableSinkBase.ElasticsearchUpsertSinkFunction
Sink function for converting upserts into Elasticsearch
ActionRequest s. |
ElasticsearchUpsertTableSinkBase.Host
Entity for describing a host of Elasticsearch.
|
ElasticsearchUpsertTableSinkBase.RequestFactory
For version-agnostic creating of
ActionRequest s. |
ElasticsearchUpsertTableSinkBase.SinkOption
Keys for optional parameterization of the sink.
|
ElasticsearchUpsertTableSinkFactoryBase
Version-agnostic table factory for creating an
UpsertStreamTableSink for Elasticsearch. |
RequestIndexer
Users add multiple delete, index or update requests 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. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.