You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jb...@apache.org on 2017/06/07 06:05:23 UTC
[2/2] beam git commit: [BEAM-245] This closes #592
[BEAM-245] This closes #592
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c189d5c0
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c189d5c0
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/c189d5c0
Branch: refs/heads/master
Commit: c189d5c0e4582b446564db9cbf1ae06970f6079d
Parents: 3cc4ff6 0b0bb3d
Author: Jean-Baptiste Onofré <jb...@apache.org>
Authored: Wed Jun 7 08:05:15 2017 +0200
Committer: Jean-Baptiste Onofré <jb...@apache.org>
Committed: Wed Jun 7 08:05:15 2017 +0200
----------------------------------------------------------------------
sdks/java/io/cassandra/pom.xml | 113 ++++
.../beam/sdk/io/cassandra/CassandraIO.java | 510 +++++++++++++++++++
.../beam/sdk/io/cassandra/CassandraService.java | 66 +++
.../sdk/io/cassandra/CassandraServiceImpl.java | 398 +++++++++++++++
.../beam/sdk/io/cassandra/package-info.java | 22 +
.../beam/sdk/io/cassandra/CassandraIOIT.java | 254 +++++++++
.../beam/sdk/io/cassandra/CassandraIOTest.java | 279 ++++++++++
.../io/cassandra/CassandraServiceImplTest.java | 138 +++++
.../sdk/io/cassandra/CassandraTestDataSet.java | 153 ++++++
.../sdk/io/common/IOTestPipelineOptions.java | 10 +
sdks/java/io/pom.xml | 1 +
11 files changed, 1944 insertions(+)
----------------------------------------------------------------------