This is an automated email from the ASF dual-hosted git repository.
aromanenko pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 9e929bd Merge pull request #15467: [BEAM-12851] Map output table names
add e12fc33 [BEAM-9008] adds CassandraIO.readAll
add b6c62ca Merge pull request #10546: [BEAM-9008] Add CassandraIO
readAll method
No new revisions were added by this update.
Summary of changes:
.../apache/beam/sdk/io/cassandra/CassandraIO.java | 540 ++++++---------------
.../beam/sdk/io/cassandra/ConnectionManager.java | 83 ++++
.../beam/sdk/io/cassandra/DefaultObjectMapper.java | 2 +-
.../io/cassandra/DefaultObjectMapperFactory.java | 2 +-
.../org/apache/beam/sdk/io/cassandra/ReadFn.java | 120 +++++
.../apache/beam/sdk/io/cassandra/RingRange.java | 46 +-
.../beam/sdk/io/cassandra/SplitGenerator.java | 16 +-
.../beam/sdk/io/cassandra/CassandraIOTest.java | 313 ++++++------
8 files changed, 555 insertions(+), 567 deletions(-)
create mode 100644
sdks/java/io/cassandra/src/main/java/org/apache/beam/sdk/io/cassandra/ConnectionManager.java
create mode 100644
sdks/java/io/cassandra/src/main/java/org/apache/beam/sdk/io/cassandra/ReadFn.java
