Uses of Interface
org.apache.flink.streaming.connectors.elasticsearch.RequestIndexer

Packages that use RequestIndexer

Package	Description
org.apache.flink.streaming.connectors.elasticsearch
org.apache.flink.streaming.connectors.elasticsearch.util
org.apache.flink.streaming.connectors.elasticsearch6
org.apache.flink.streaming.connectors.elasticsearch7

Uses of RequestIndexer in org.apache.flink.streaming.connectors.elasticsearch

Methods in org.apache.flink.streaming.connectors.elasticsearch that return RequestIndexer

Modifier and Type	Method and Description
default RequestIndexer	ElasticsearchApiCallBridge.createBulkProcessorIndexer(org.elasticsearch.action.bulk.BulkProcessor bulkProcessor, boolean flushOnCheckpoint, AtomicLong numPendingRequestsRef) Creates a RequestIndexer that is able to work with BulkProcessor binary compatible.

Methods in org.apache.flink.streaming.connectors.elasticsearch with parameters of type RequestIndexer

Modifier and Type	Method and Description
void	ActionRequestFailureHandler.onFailure(org.elasticsearch.action.ActionRequest action, Throwable failure, int restStatusCode, RequestIndexer indexer) Handle a failed ActionRequest.
void	ElasticsearchSinkFunction.process(T element, RuntimeContext ctx, RequestIndexer indexer) Process the incoming element to produce multiple ActionsRequests.
void	ElasticsearchUpsertTableSinkBase.ElasticsearchUpsertSinkFunction.process(Tuple2<Boolean,Row> element, RuntimeContext ctx, RequestIndexer indexer)

Uses of RequestIndexer in org.apache.flink.streaming.connectors.elasticsearch.util

Methods in org.apache.flink.streaming.connectors.elasticsearch.util with parameters of type RequestIndexer

Modifier and Type	Method and Description
void	RetryRejectedExecutionFailureHandler.onFailure(org.elasticsearch.action.ActionRequest action, Throwable failure, int restStatusCode, RequestIndexer indexer)
void	IgnoringFailureHandler.onFailure(org.elasticsearch.action.ActionRequest action, Throwable failure, int restStatusCode, RequestIndexer indexer)
void	NoOpFailureHandler.onFailure(org.elasticsearch.action.ActionRequest action, Throwable failure, int restStatusCode, RequestIndexer indexer)

Uses of RequestIndexer in org.apache.flink.streaming.connectors.elasticsearch6

Methods in org.apache.flink.streaming.connectors.elasticsearch6 that return RequestIndexer

Modifier and Type	Method and Description
RequestIndexer	Elasticsearch6ApiCallBridge.createBulkProcessorIndexer(org.elasticsearch.action.bulk.BulkProcessor bulkProcessor, boolean flushOnCheckpoint, AtomicLong numPendingRequestsRef)

Uses of RequestIndexer in org.apache.flink.streaming.connectors.elasticsearch7

Methods in org.apache.flink.streaming.connectors.elasticsearch7 that return RequestIndexer

Modifier and Type	Method and Description
RequestIndexer	Elasticsearch7ApiCallBridge.createBulkProcessorIndexer(org.elasticsearch.action.bulk.BulkProcessor bulkProcessor, boolean flushOnCheckpoint, AtomicLong numPendingRequestsRef)