Constructor and Description |
---|
ElasticsearchSinkBase(ElasticsearchApiCallBridge<C> callBridge,
Map<String,String> userConfig,
ElasticsearchSinkFunction<T> elasticsearchSinkFunction,
ActionRequestFailureHandler failureHandler) |
Modifier and Type | Class and Description |
---|---|
class |
IgnoringFailureHandler
Ignores all kinds of failures and drops the affected
ActionRequest . |
class |
NoOpFailureHandler
An
ActionRequestFailureHandler that simply fails the sink on any failures. |
class |
RetryRejectedExecutionFailureHandler
An
ActionRequestFailureHandler that re-adds requests that failed due to temporary EsRejectedExecutionException s (which means that Elasticsearch node queues are currently full),
and fails for all other failures. |
Constructor and Description |
---|
ElasticsearchSink(Map<String,String> userConfig,
List<InetSocketAddress> transportAddresses,
ElasticsearchSinkFunction<T> elasticsearchSinkFunction,
ActionRequestFailureHandler failureHandler)
Creates a new
ElasticsearchSink that connects to the cluster using a TransportClient . |
Modifier and Type | Method and Description |
---|---|
void |
ElasticsearchSink.Builder.setFailureHandler(ActionRequestFailureHandler failureHandler)
Sets a failure handler for action requests.
|
Modifier and Type | Method and Description |
---|---|
void |
ElasticsearchSink.Builder.setFailureHandler(ActionRequestFailureHandler failureHandler)
Sets a failure handler for action requests.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.