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 |
---|
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. |
ElasticsearchApiCallBridge
An
ElasticsearchApiCallBridge is used to bridge incompatible Elasticsearch Java API calls
across different versions. |
ElasticsearchSinkBase.BulkFlushBackoffPolicy
Provides a backoff policy for bulk requests.
|
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. |
ElasticsearchUpsertTableSinkBase.Host
Entity for describing a host of Elasticsearch.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.