[BEAM-425] This closes #1439
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/926ec8e8 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/926ec8e8 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/926ec8e8 Branch: refs/heads/master Commit: 926ec8e8066f2161af878d19b75a1ea3774500a3 Parents: d1d85df 6412389 Author: Jean-Baptiste Onofré <[email protected]> Authored: Wed Jan 4 13:53:24 2017 +0100 Committer: Jean-Baptiste Onofré <[email protected]> Committed: Wed Jan 4 13:53:24 2017 +0100 ---------------------------------------------------------------------- sdks/java/io/elasticsearch/pom.xml | 175 ++++ .../sdk/io/elasticsearch/ElasticsearchIO.java | 819 +++++++++++++++++++ .../beam/sdk/io/elasticsearch/package-info.java | 20 + .../elasticsearch/ElasticSearchIOTestUtils.java | 129 +++ .../io/elasticsearch/ElasticsearchIOTest.java | 358 ++++++++ sdks/java/io/pom.xml | 1 + 6 files changed, 1502 insertions(+) ----------------------------------------------------------------------
