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

Reply via email to