This is an automated email from the ASF dual-hosted git repository.
echauchot pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from a06d9eb Merge pull request #7846 from drieber/flatten-unzipping
new 2e76a53 [BEAM-4164] Add Cassandra embedded cluster + start and stop
methods
new eaa0253 [BEAM-4164] Add Cassandra embedded cluster purge
new aeac066 [BEAM-4164] Add rows insert and manual refresh of the cluster
new 5ab4013 [BEAM-4164] Remove CassandraService (as its main use was to
inject a mock service)
new a3eccaa [BEAM-4164] Rename Mutate<T> to Write<T> for consistency
among the IOs. But keep mutator terminology
new 1b97ae3 [BEAM-4164] Rename one of the split methods and regroup
getEstimatedSize methods
new 68df83d [BEAM-4164] Remove Writer and Deleter classes because they
were just wrapping a Mutator constructor
new 841fb25 [BEAM-4164] Fix comments
new c29d90b [BEAM-4164] Move former CassandraServiceImplTest utils tests
to CassandraIOTest
new ef43d67 [BEAM-4164] Split back getEstimatedSizeBytesFromTokenRanges
to be able to test it
new 400bcf2 [BEAM-4164] Use embedded cassandra instead of
FakeCassandraService in tests
new ad6e616 [BEAM-4164] Add missing testSplit
new 37cf2e2 [BEAM-4164] Remove CassandraService and related
new 9e77ff0 [BEAM-4164] Put mutators transient
new c25049a [BEAM-4164] Fix deps conflict in build.
new e39e3b1 [BEAM-6591] Fix split
new 22b4eb2 [BEAM-4164] Fix testDelete: missing PartitionKey
new eb48b06 [BEAM-4164] Reduce test time
new cbd96c6 [BEAM-4164] Fix spotless
new 13b6c62 [BEAM-4164] remove unneeded cassandra version definition
property
new adf86d5 [BEAM-4164] Cassandra version was updated, size of the
keyspace is not deterministic. So add a error percentage
new ea551e3 [BEAM-4164] Update checkstyle exceptions to allow non-vendor
guava in CassandraIO
new fef512e Merge pull request #7751 from
echauchot/BEAM-4164-cassandraIO-embedded
The 20228 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../src/main/resources/beam/suppressions.xml | 2 +-
sdks/java/io/cassandra/build.gradle | 7 +
.../apache/beam/sdk/io/cassandra/CassandraIO.java | 546 ++++++++++++++++++---
.../beam/sdk/io/cassandra/CassandraService.java | 63 ---
.../sdk/io/cassandra/CassandraServiceImpl.java | 505 -------------------
.../beam/sdk/io/cassandra/SplitGenerator.java | 5 +-
.../beam/sdk/io/cassandra/CassandraIOTest.java | 443 ++++++++++-------
.../sdk/io/cassandra/CassandraServiceImplTest.java | 117 -----
8 files changed, 749 insertions(+), 939 deletions(-)
delete mode 100644
sdks/java/io/cassandra/src/main/java/org/apache/beam/sdk/io/cassandra/CassandraService.java
delete mode 100644
sdks/java/io/cassandra/src/main/java/org/apache/beam/sdk/io/cassandra/CassandraServiceImpl.java
delete mode 100644
sdks/java/io/cassandra/src/test/java/org/apache/beam/sdk/io/cassandra/CassandraServiceImplTest.java
