Constructor and Description |
---|
ElasticsearchSink(Map<String,String> userConfig,
ElasticsearchSinkFunction<T> elasticsearchSinkFunction)
Creates a new
ElasticsearchSink that connects to the cluster using an embedded Node . |
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)
Creates a new
ElasticsearchSink that connects to the cluster using a TransportClient . |
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) |
Constructor and Description |
---|
ElasticsearchSink(Map<String,String> userConfig,
List<InetSocketAddress> transportAddresses,
ElasticsearchSinkFunction<T> elasticsearchSinkFunction)
Creates a new
ElasticsearchSink that connects to the cluster using a TransportClient . |
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)
Creates a new
ElasticsearchSink that connects to the cluster using a TransportClient . |
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 . |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.