Package | Description |
---|---|
org.apache.flink.streaming.connectors.elasticsearch2 |
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.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.