Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id DCBB6200B72 for ; Fri, 26 Aug 2016 18:50:50 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id DB21B160AC3; Fri, 26 Aug 2016 16:50:50 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 080BE160A94 for ; Fri, 26 Aug 2016 18:50:49 +0200 (CEST) Received: (qmail 94002 invoked by uid 500); 26 Aug 2016 16:50:49 -0000 Mailing-List: contact commits-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list commits@flink.apache.org Received: (qmail 93992 invoked by uid 99); 26 Aug 2016 16:50:49 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 26 Aug 2016 16:50:49 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 00F5ADFF56; Fri, 26 Aug 2016 16:50:48 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: sewen@apache.org To: commits@flink.apache.org Date: Fri, 26 Aug 2016 16:50:48 -0000 Message-Id: <10ac0c731877403ca120b06ea10ee251@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [1/2] flink git commit: [FLINK-4480] [elasticsearch connector] Fix link to elastic.co in documentation archived-at: Fri, 26 Aug 2016 16:50:51 -0000 Repository: flink Updated Branches: refs/heads/master 6a456c673 -> 3505316c6 [FLINK-4480] [elasticsearch connector] Fix link to elastic.co in documentation This also includes minor code and test cleanups. This closes #2416 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3505316c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3505316c Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/3505316c Branch: refs/heads/master Commit: 3505316c6446606555f4ae7cc18ba5e872ff687d Parents: 53f5a8c Author: smarthi Authored: Wed Aug 24 18:07:23 2016 -0400 Committer: Stephan Ewen Committed: Fri Aug 26 17:53:19 2016 +0200 ---------------------------------------------------------------------- docs/dev/connectors/index.md | 2 +- .../elasticsearch/examples/ElasticsearchExample.java | 3 +-- .../flink-connector-elasticsearch2/pom.xml | 2 +- .../elasticsearch2/examples/ElasticsearchExample.java | 11 +++++++++-- 4 files changed, 12 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/3505316c/docs/dev/connectors/index.md ---------------------------------------------------------------------- diff --git a/docs/dev/connectors/index.md b/docs/dev/connectors/index.md index c49c8c2..59b5e7b 100644 --- a/docs/dev/connectors/index.md +++ b/docs/dev/connectors/index.md @@ -31,7 +31,7 @@ Currently these systems are supported: * [Apache Kafka](https://kafka.apache.org/) (sink/source) * [Elasticsearch](https://elastic.co/) (sink) - * [Elasticsearch 2x](https://elastic.com) (sink) + * [Elasticsearch 2x](https://elastic.co/) (sink) * [Hadoop FileSystem](http://hadoop.apache.org) (sink) * [RabbitMQ](http://www.rabbitmq.com/) (sink/source) * [Amazon Kinesis Streams](http://aws.amazon.com/kinesis/streams/) (sink/source) http://git-wip-us.apache.org/repos/asf/flink/blob/3505316c/flink-streaming-connectors/flink-connector-elasticsearch/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/examples/ElasticsearchExample.java ---------------------------------------------------------------------- diff --git a/flink-streaming-connectors/flink-connector-elasticsearch/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/examples/ElasticsearchExample.java b/flink-streaming-connectors/flink-connector-elasticsearch/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/examples/ElasticsearchExample.java index f8f658b..136ae77 100644 --- a/flink-streaming-connectors/flink-connector-elasticsearch/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/examples/ElasticsearchExample.java +++ b/flink-streaming-connectors/flink-connector-elasticsearch/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/examples/ElasticsearchExample.java @@ -17,7 +17,6 @@ package org.apache.flink.streaming.connectors.elasticsearch.examples; -import com.google.common.collect.Maps; import org.apache.flink.api.common.functions.RuntimeContext; import org.apache.flink.streaming.api.datastream.DataStreamSource; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; @@ -58,7 +57,7 @@ public class ElasticsearchExample { } }); - Map config = Maps.newHashMap(); + Map config = new HashMap<>(); // This instructs the sink to emit after every element, otherwise they would be buffered config.put(ElasticsearchSink.CONFIG_KEY_BULK_FLUSH_MAX_ACTIONS, "1"); http://git-wip-us.apache.org/repos/asf/flink/blob/3505316c/flink-streaming-connectors/flink-connector-elasticsearch2/pom.xml ---------------------------------------------------------------------- diff --git a/flink-streaming-connectors/flink-connector-elasticsearch2/pom.xml b/flink-streaming-connectors/flink-connector-elasticsearch2/pom.xml index cb8ad62..51f55b3 100644 --- a/flink-streaming-connectors/flink-connector-elasticsearch2/pom.xml +++ b/flink-streaming-connectors/flink-connector-elasticsearch2/pom.xml @@ -37,7 +37,7 @@ under the License. - 2.2.1 + 2.3.5 http://git-wip-us.apache.org/repos/asf/flink/blob/3505316c/flink-streaming-connectors/flink-connector-elasticsearch2/src/test/java/org/apache/flink/streaming/connectors/elasticsearch2/examples/ElasticsearchExample.java ---------------------------------------------------------------------- diff --git a/flink-streaming-connectors/flink-connector-elasticsearch2/src/test/java/org/apache/flink/streaming/connectors/elasticsearch2/examples/ElasticsearchExample.java b/flink-streaming-connectors/flink-connector-elasticsearch2/src/test/java/org/apache/flink/streaming/connectors/elasticsearch2/examples/ElasticsearchExample.java index 77520b5..05760e8 100644 --- a/flink-streaming-connectors/flink-connector-elasticsearch2/src/test/java/org/apache/flink/streaming/connectors/elasticsearch2/examples/ElasticsearchExample.java +++ b/flink-streaming-connectors/flink-connector-elasticsearch2/src/test/java/org/apache/flink/streaming/connectors/elasticsearch2/examples/ElasticsearchExample.java @@ -26,7 +26,11 @@ import org.apache.flink.streaming.connectors.elasticsearch2.RequestIndexer; import org.elasticsearch.action.index.IndexRequest; import org.elasticsearch.client.Requests; +import java.net.InetAddress; +import java.net.InetSocketAddress; +import java.util.ArrayList; import java.util.HashMap; +import java.util.List; import java.util.Map; /** @@ -60,7 +64,10 @@ public class ElasticsearchExample { // This instructs the sink to emit after every element, otherwise they would be buffered config.put(ElasticsearchSink.CONFIG_KEY_BULK_FLUSH_MAX_ACTIONS, "1"); - source.addSink(new ElasticsearchSink<>(config, null, new ElasticsearchSinkFunction(){ + List transports = new ArrayList<>(); + transports.add(new InetSocketAddress(InetAddress.getByName("127.0.0.1"), 9300)); + + source.addSink(new ElasticsearchSink<>(config, transports, new ElasticsearchSinkFunction(){ @Override public void process(String element, RuntimeContext ctx, RequestIndexer indexer) { indexer.add(createIndexRequest(element)); @@ -70,7 +77,7 @@ public class ElasticsearchExample { env.execute("Elasticsearch Example"); } - public static IndexRequest createIndexRequest(String element) { + private static IndexRequest createIndexRequest(String element) { Map json = new HashMap<>(); json.put("data", element);