This is an automated email from the ASF dual-hosted git repository.
iamaleksey pushed a change to branch cep-45-mutation-tracking
in repository https://gitbox.apache.org/repos/asf/cassandra.git
from e982cf69b4 Fix MutationId class hierarchy and related maps lookup
issues
add 16bb95fa15 CEP-45: Implement independent mutation tracking versioning
No new revisions were added by this update.
Summary of changes:
.../config/CassandraRelevantProperties.java | 2 +
.../db/AbstractReadCommandVerbHandler.java | 2 +-
.../db/EmbeddableSinglePartitionReadCommand.java | 12 +-
.../org/apache/cassandra/db/IReadResponse.java | 12 +-
src/java/org/apache/cassandra/db/Mutation.java | 65 +++++-----
.../org/apache/cassandra/db/SystemKeyspace.java | 5 +-
.../exceptions/FunctionExecutionException.java | 7 +-
.../io/AsymmetricVersionedSerializer.java | 24 ----
.../io/EmbeddedAsymmetricVersionedSerializer.java | 34 +++++-
.../cassandra/io/MessageVersionProvider.java | 24 ----
.../io/sstable/metadata/StatsMetadata.java | 6 +-
src/java/org/apache/cassandra/net/Verb.java | 54 ++++-----
.../messages/MutationTrackingSyncRequest.java | 17 +--
.../messages/MutationTrackingSyncResponse.java | 35 ++++--
.../cassandra/repair/messages/PrepareMessage.java | 7 +-
.../cassandra/repair/messages/SyncRequest.java | 8 +-
.../cassandra/repair/messages/SyncResponse.java | 8 +-
.../cassandra/replication/ActivatedTransfers.java | 38 +++---
.../cassandra/replication/ActivationRequest.java | 51 ++++----
.../cassandra/replication/ActivationResponse.java | 25 ++--
.../cassandra/replication/ActiveLogReconciler.java | 4 +-
.../cassandra/replication/BroadcastLogOffsets.java | 30 ++---
.../cassandra/replication/CoordinatedTransfer.java | 4 +-
.../cassandra/replication/CoordinatorLogId.java | 21 +++-
.../cassandra/replication/ForwardedWrite.java | 31 ++---
.../ImmutableCoordinatorLogOffsets.java | 44 ++++---
.../cassandra/replication/Log2OffsetsMap.java | 41 -------
.../apache/cassandra/replication/MutationId.java | 14 +--
.../cassandra/replication/MutationSummary.java | 51 ++++----
.../replication/MutationTrackingService.java | 2 +-
.../org/apache/cassandra/replication/Offsets.java | 19 ++-
.../replication/PullMutationsRequest.java | 34 +++---
.../cassandra/replication/PushMutationRequest.java | 15 ++-
.../replication/ReconciledKeyspaceOffsets.java | 75 ++++++------
.../replication/ReconciledLogSnapshot.java | 52 +++-----
.../cassandra/replication/ShortMutationId.java | 10 +-
.../replication/TrackedImportTransfer.java | 2 +-
.../cassandra/replication/TransferFailed.java | 16 ++-
.../org/apache/cassandra/replication/Version.java | 131 +++++++++++++++++++++
.../VersionedAsymmetricSerializer.java} | 7 +-
.../{io => replication}/VersionedSerializer.java | 5 +-
.../service/accord/AccordSerializers.java | 7 --
.../serializers/AsymmetricVersionedSerializer.java | 23 ----
.../accord/serializers/IVersionedSerializer.java | 25 ----
.../service/accord/serializers/Version.java | 4 +-
.../service/paxos/CasForwardResponse.java | 7 +-
.../service/reads/tracked/ReadReconcileAck.java | 17 ++-
.../service/reads/tracked/ReadReconciliations.java | 6 +-
.../service/reads/tracked/TrackedDataResponse.java | 92 ++++++++-------
.../service/reads/tracked/TrackedRead.java | 110 ++++++++---------
.../reads/tracked/TrackedSummaryResponse.java | 48 ++++----
.../cassandra/streaming/LogStreamHeader.java | 24 ++--
.../cassandra/streaming/LogStreamManifest.java | 77 ++++++------
.../messages/IncomingMutationLogStreamMessage.java | 8 +-
.../messages/MutationLogReceivedMessage.java | 18 ++-
.../messages/OutgoingMutationLogStreamMessage.java | 7 +-
.../streaming/messages/PrepareSynAckMessage.java | 6 +-
.../streaming/messages/PrepareSynMessage.java | 12 +-
.../streaming/messages/StreamMessageHeader.java | 6 +-
.../AdvanceMutationTrackingMigration.java | 8 +-
.../apache/cassandra/utils/ArraySerializers.java | 24 ++++
.../cassandra/utils/CollectionSerializers.java | 83 +++++++------
.../apache/cassandra/utils/Int64Serializer.java | 22 +++-
...{Int32Serializer.java => StringSerializer.java} | 35 +++---
src/java/org/apache/cassandra/utils/TimeUUID.java | 2 +
.../distributed/test/ReadRepairTestBase.java | 16 +--
.../test/repair/MutationTrackingRepairTest.java | 4 +-
.../test/tracking/MutationTrackingUtils.java | 39 +-----
.../test/tracking/TrackedImportFailureTest.java | 12 +-
.../config/DatabaseDescriptorRefTest.java | 1 -
.../apache/cassandra/io/IVersionedSerializers.java | 1 -
.../UnversionedSerializers.java} | 15 +--
.../replication/ActivatedTransfersTest.java | 3 +-
.../ActivationRequestSerializationTest.java | 6 +-
.../ActivationResponseSerializationTest.java | 6 +-
.../replication/CoordinatorLogOffsetsTest.java | 7 +-
.../apache/cassandra/replication/OffsetsTest.java | 5 +-
77 files changed, 913 insertions(+), 917 deletions(-)
delete mode 100644 src/java/org/apache/cassandra/io/MessageVersionProvider.java
create mode 100644 src/java/org/apache/cassandra/replication/Version.java
copy src/java/org/apache/cassandra/{config/MutationTrackingSpec.java =>
replication/VersionedAsymmetricSerializer.java} (78%)
copy src/java/org/apache/cassandra/{io =>
replication}/VersionedSerializer.java (84%)
delete mode 100644
src/java/org/apache/cassandra/service/accord/serializers/AsymmetricVersionedSerializer.java
copy src/java/org/apache/cassandra/utils/{Int32Serializer.java =>
StringSerializer.java} (59%)
copy test/unit/org/apache/cassandra/io/{IVersionedSerializers.java =>
filesystem/UnversionedSerializers.java} (78%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
