Modifier and Type | Class and Description |
---|---|
static class |
ElasticsearchUpsertTableSinkBase.ElasticsearchUpsertSinkFunction
Sink function for converting upserts into Elasticsearch
ActionRequest s. |
Constructor and Description |
---|
ElasticsearchSinkBase(ElasticsearchApiCallBridge<C> 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 . |
Constructor and Description |
---|
Builder(List<org.apache.http.HttpHost> httpHosts,
ElasticsearchSinkFunction<T> elasticsearchSinkFunction)
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)
Creates a new
ElasticsearchSink that connects to the cluster using a RestHighLevelClient . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.