This is an automated email from the ASF dual-hosted git repository.
aleksey pushed a change to branch cep-45-mutation-tracking
in repository https://gitbox.apache.org/repos/asf/cassandra.git
from 6430d497bb Fixed LegacySSTableTest to reflect thew new
be_index_summary table type
add 418a19dc31 Implement unified log reconciliation
No new revisions were added by this update.
Summary of changes:
.../db/AbstractReadCommandVerbHandler.java | 9 +
src/java/org/apache/cassandra/db/Keyspace.java | 24 +-
.../apache/cassandra/db/MutationVerbHandler.java | 1 +
src/java/org/apache/cassandra/dht/Splitter.java | 2 +-
.../apache/cassandra/journal/ActiveSegment.java | 16 +-
.../apache/cassandra/journal/EntrySerializer.java | 10 +
src/java/org/apache/cassandra/journal/Flusher.java | 8 +-
src/java/org/apache/cassandra/journal/Journal.java | 42 ++
.../apache/cassandra/journal/RecordPointer.java | 14 +-
src/java/org/apache/cassandra/journal/Segment.java | 11 +
.../org/apache/cassandra/journal/Segments.java | 9 +
.../cassandra/locator/EndpointsForRange.java | 5 +
src/java/org/apache/cassandra/net/Message.java | 11 +-
src/java/org/apache/cassandra/net/Verb.java | 37 +-
.../cassandra/replication/ActiveLogReconciler.java | 207 +++++++
...icatedOffsets.java => BroadcastLogOffsets.java} | 20 +-
.../cassandra/replication/CoordinatorLog.java | 130 +++--
.../cassandra/replication/ExpiredStatePurger.java | 112 ++++
.../cassandra/replication/ForwardedWrite.java | 236 +++-----
.../cassandra/replication/IncomingMutations.java | 158 ++++++
.../cassandra/replication/Log2OffsetsMap.java | 75 ++-
.../cassandra/replication/MutationJournal.java | 21 +-
.../cassandra/replication/MutationSummary.java | 17 +
.../replication/MutationTrackingService.java | 228 ++++++--
...dinatorLogOffsets.java => Node2OffsetsMap.java} | 37 +-
.../org/apache/cassandra/replication/Offsets.java | 74 ++-
.../cassandra/replication/OutgoingMutations.java | 154 +++++
.../replication/PullMutationsRequest.java | 75 +++
.../cassandra/replication/PushMutationRequest.java | 183 ++++++
.../cassandra/replication/ReconciliationPlan.java | 210 -------
.../org/apache/cassandra/replication/Shard.java | 89 ++-
.../cassandra/replication/TrackedWriteRequest.java | 36 +-
.../replication/UnreconciledMutations.java | 160 +++++-
.../replication/UnreconciledMutationsReplica.java | 193 -------
.../org/apache/cassandra/service/StorageProxy.java | 5 +-
.../service/TrackedWriteResponseHandler.java | 16 +-
.../service/reads/range/RangeCommandIterator.java | 6 +-
.../reads/tracked/ExtendingCompletedRead.java | 12 +-
.../reads/tracked/FilteredFollowupRead.java | 17 +-
.../reads/tracked/PartialTrackedRangeRead.java | 13 +-
.../service/reads/tracked/PartialTrackedRead.java | 23 +-
.../tracked/PartialTrackedSinglePartitionRead.java | 2 +-
...dReconcileNotify.java => ReadReconcileAck.java} | 48 +-
.../reads/tracked/ReadReconcileReceive.java | 137 -----
.../service/reads/tracked/ReadReconcileSend.java | 166 ------
.../service/reads/tracked/ReadReconciliations.java | 396 +++++++++++++
.../reads/tracked/TrackedLocalReadCoordinator.java | 617 ---------------------
.../service/reads/tracked/TrackedLocalReads.java | 272 +++++----
.../service/reads/tracked/TrackedRead.java | 160 +++---
.../reads/tracked/TrackedSummaryResponse.java | 49 +-
.../distributed/test/ReadRepairTestBase.java | 19 +-
.../tracking/MutationTrackingPendingReadTest.java | 4 +-
.../test/tracking/MutationTrackingTest.java | 58 +-
.../replication/CoordinatorLogOffsetsTest.java | 12 +-
.../apache/cassandra/replication/OffsetsTest.java | 95 +++-
55 files changed, 2757 insertions(+), 1984 deletions(-)
create mode 100644
src/java/org/apache/cassandra/replication/ActiveLogReconciler.java
rename src/java/org/apache/cassandra/replication/{ShardReplicatedOffsets.java
=> BroadcastLogOffsets.java} (82%)
create mode 100644
src/java/org/apache/cassandra/replication/ExpiredStatePurger.java
create mode 100644
src/java/org/apache/cassandra/replication/IncomingMutations.java
copy src/java/org/apache/cassandra/replication/{CoordinatorLogOffsets.java =>
Node2OffsetsMap.java} (54%)
create mode 100644
src/java/org/apache/cassandra/replication/OutgoingMutations.java
create mode 100644
src/java/org/apache/cassandra/replication/PullMutationsRequest.java
create mode 100644
src/java/org/apache/cassandra/replication/PushMutationRequest.java
delete mode 100644
src/java/org/apache/cassandra/replication/ReconciliationPlan.java
delete mode 100644
src/java/org/apache/cassandra/replication/UnreconciledMutationsReplica.java
rename
src/java/org/apache/cassandra/service/reads/tracked/{ReadReconcileNotify.java
=> ReadReconcileAck.java} (50%)
delete mode 100644
src/java/org/apache/cassandra/service/reads/tracked/ReadReconcileReceive.java
delete mode 100644
src/java/org/apache/cassandra/service/reads/tracked/ReadReconcileSend.java
create mode 100644
src/java/org/apache/cassandra/service/reads/tracked/ReadReconciliations.java
delete mode 100644
src/java/org/apache/cassandra/service/reads/tracked/TrackedLocalReadCoordinator.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
