[2/2] beam git commit: [BEAM-245] This closes #592

[jbonofre]

[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é <jbono...@apache.org>
Authored: Wed Jun 7 08:05:15 2017 +0200
Committer: Jean-Baptiste Onofré <jbono...@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(+)
----------------------------------------------------------------------