Constructor and Description |
---|
ElasticsearchSink(Map<String,String> userConfig,
ElasticsearchSinkFunction<T> elasticsearchSinkFunction,
ActionRequestFailureHandler failureHandler)
Creates a new
ElasticsearchSink that connects to the cluster using an embedded Node . |
ElasticsearchSink(Map<String,String> userConfig,
List<org.elasticsearch.common.transport.TransportAddress> transportAddresses,
ElasticsearchSinkFunction<T> elasticsearchSinkFunction,
ActionRequestFailureHandler failureHandler)
Creates a new
ElasticsearchSink that connects to the cluster using a TransportClient . |
ElasticsearchSinkBase(ElasticsearchApiCallBridge callBridge,
Map<String,String> userConfig,
ElasticsearchSinkFunction<T> elasticsearchSinkFunction,
ActionRequestFailureHandler failureHandler) |
Modifier and Type | Class and Description |
---|---|
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 . |
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.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.