Constructor and Description |
---|
ElasticsearchSinkBase(ElasticsearchApiCallBridge<C> callBridge,
Map<String,String> userConfig,
ElasticsearchSinkFunction<T> elasticsearchSinkFunction,
ActionRequestFailureHandler failureHandler) |
Constructor and Description |
---|
Builder(List<org.apache.http.HttpHost> httpHosts,
ElasticsearchSinkFunction<T> elasticsearchSinkFunction)
Deprecated.
Creates a new
ElasticsearchSink that connects to the cluster using a RestHighLevelClient . |
Constructor and Description |
---|
Builder(List<org.apache.http.HttpHost> httpHosts,
ElasticsearchSinkFunction<T> elasticsearchSinkFunction)
Deprecated.
Creates a new
ElasticsearchSink that connects to the cluster using a RestHighLevelClient . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.