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
Deprecated.
This hase been deprecated and will be removed in the future.
|
Modifier and Type | Method and Description |
---|---|
void |
ElasticsearchSink.Builder.setFailureHandler(ActionRequestFailureHandler failureHandler)
Deprecated.
Sets a failure handler for action requests.
|
Modifier and Type | Method and Description |
---|---|
void |
ElasticsearchSink.Builder.setFailureHandler(ActionRequestFailureHandler failureHandler)
Deprecated.
Sets a failure handler for action requests.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.