This is an automated email from the ASF dual-hosted git repository.
bdeggleston pushed a change to branch cep-45-mutation-tracking
in repository https://gitbox.apache.org/repos/asf/cassandra.git
omit 510053a4a6 Add mutation tracking summary to SSTables
omit dc13f327eb Fix-up offset broadcasting logic
omit 70809160af Fixup inter-DC forwarding of writes from a
coordinator-replica (fixup)
omit e0d2daa86c Implement coordinator log offset broadcasting
omit 2af0a2cafb CEP-45: Query forwarding
omit 6376bd3f6d Fix mutation tracking startup
omit 1ed5097bba Fix test failure:
cqlshlib.test.test_cqlsh_output.TestCqlshOutput::test_describe_schema_output
omit c00c738a64 Mutation tracking journal integration, read, and write path
new 7a6d00e879 Mutation tracking journal integration, read, and write path
new 221da62919 Fix test failure:
cqlshlib.test.test_cqlsh_output.TestCqlshOutput::test_describe_schema_output
new 6baab9889b Fix mutation tracking startup
new 334cfd0efd CEP-45: Query forwarding
new 4db4551f43 Implement coordinator log offset broadcasting
new 1c747d340c Fixup inter-DC forwarding of writes from a
coordinator-replica (fixup)
new 4a5dc769a7 Fix-up offset broadcasting logic
new a5f7e08b11 Add mutation tracking summary to SSTables
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (510053a4a6)
\
N -- N -- N refs/heads/cep-45-mutation-tracking (a5f7e08b11)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 8 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:
.../org/apache/cassandra/cql3/QueryProcessor.java | 14 +-
...er.java => AbstractReadCommandVerbHandler.java} | 106 +--
.../cassandra/db/PartitionRangeReadCommand.java | 113 +--
src/java/org/apache/cassandra/db/ReadCommand.java | 342 ++++-----
.../cassandra/db/ReadCommandVerbHandler.java | 161 +----
.../cassandra/db/ReadExecutionController.java | 2 +-
src/java/org/apache/cassandra/db/ReadResponse.java | 38 +-
.../cassandra/db/SinglePartitionReadCommand.java | 117 +---
...terator.java => AbstractPartitionIterator.java} | 14 +-
.../db/partitions/PartitionIterators.java | 43 ++
...itionUpdater.java => SimpleBTreePartition.java} | 127 +---
...edRowIterator.java => AbstractRowIterator.java} | 56 +-
.../cassandra/db/rows/ComplexColumnData.java | 2 +-
.../org/apache/cassandra/db/rows/RowIterators.java | 281 +++++++-
.../cassandra/db/rows/UnfilteredSerializer.java | 8 +-
src/java/org/apache/cassandra/net/Message.java | 6 +
src/java/org/apache/cassandra/net/Verb.java | 27 +-
.../cassandra/replication/CoordinatorLog.java | 24 +-
.../cassandra/replication/Log2OffsetsMap.java | 230 ++++++
.../cassandra/replication/MutationSummary.java | 16 +-
.../replication/MutationTrackingService.java | 16 +-
.../org/apache/cassandra/replication/Offsets.java | 770 +++++++++++++--------
.../cassandra/replication/ReconciliationPlan.java | 146 +---
.../org/apache/cassandra/replication/Shard.java | 6 +-
.../replication/ShardReplicatedOffsets.java | 10 +-
.../cassandra/replication/ShortMutationId.java | 5 +
.../replication/UnreconciledMutations.java | 4 +-
.../replication/UnreconciledMutationsReplica.java | 8 +-
.../org/apache/cassandra/schema/TableMetadata.java | 2 +
.../org/apache/cassandra/schema/TableParams.java | 1 -
.../org/apache/cassandra/service/StorageProxy.java | 60 +-
.../org/apache/cassandra/service/paxos/Paxos.java | 2 +-
.../cassandra/service/paxos/PaxosPrepare.java | 27 +-
.../service/reads/AbstractReadExecutor.java | 37 +-
.../reads/{untracked => }/DataResolver.java | 35 +-
.../reads/{untracked => }/DigestResolver.java | 34 +-
.../cassandra/service/reads/IReadResponse.java | 165 -----
.../cassandra/service/reads/ReadCallback.java | 10 +-
.../service/reads/ReplicaFilteringProtection.java | 7 +-
.../cassandra/service/reads/ResponseResolver.java | 23 +-
.../reads/ShortReadPartitionsProtection.java | 1 -
.../service/reads/range/RangeCommandIterator.java | 127 ++--
.../reads/range/ScanAllRangesCommandIterator.java | 4 +-
.../service/reads/range/SingleRangeResponse.java | 72 +-
.../service/reads/repair/AbstractReadRepair.java | 12 +-
.../service/reads/repair/NoopReadRepair.java | 9 +-
.../repair/PartitionIteratorMergeListener.java | 5 +-
.../cassandra/service/reads/repair/ReadRepair.java | 38 +-
.../reads/repair/ReadRepairDiagnostics.java | 4 +-
.../service/reads/repair/ReadRepairEvent.java | 10 +-
.../service/reads/repair/ReadRepairStrategy.java | 7 +-
.../reads/repair/RowIteratorMergeListener.java | 5 +-
.../reads/tracked/AbstractPartialTrackedRead.java | 154 +++++
.../reads/tracked/PartialTrackedRangeRead.java | 347 ++++++++++
.../service/reads/tracked/PartialTrackedRead.java | 88 +++
.../tracked/PartialTrackedSinglePartitionRead.java | 108 +++
.../service/reads/tracked/ReadReconcileNotify.java | 22 +-
.../reads/tracked/ReadReconcileReceive.java | 126 +---
.../service/reads/tracked/ReadReconcileSend.java | 68 +-
.../service/reads/tracked/ReadReconciliations.java | 180 -----
.../service/reads/tracked/TrackedDataResponse.java | 99 +++
.../reads/tracked/TrackedLocalReadCoordinator.java | 617 +++++++++++++++++
.../service/reads/tracked/TrackedLocalReads.java | 182 +++++
.../service/reads/tracked/TrackedRead.java | 517 ++++++++++++++
.../reads/tracked/TrackedReadReconciliation.java | 500 -------------
.../service/reads/tracked/TrackedReadResponse.java | 256 -------
.../service/reads/tracked/TrackedResolver.java | 104 ---
.../reads/tracked/TrackedSummaryResponse.java | 77 +++
.../reads/untracked/UntrackedReadRepair.java | 52 --
.../service/reads/untracked/UntrackedResolver.java | 47 --
.../cassandra/distributed/test/GroupByTest.java | 520 ++++++++------
.../test/ReadRepairRangeQueriesTest.java | 16 +-
.../test/ReadRepairSliceQueriesTest.java | 3 +-
.../distributed/test/ReadRepairTestBase.java | 1 +
.../distributed/test/ShortReadProtectionTest.java | 11 +-
.../tracking/MutationTrackingPendingReadTest.java | 51 +-
.../MutationTrackingReadReconciliationTest.java | 47 +-
.../test/tracking/MutationTrackingUtils.java | 4 +-
.../org/apache/cassandra/db/ReadCommandTest.java | 8 +-
.../db/ReadCommandVerbHandlerOutOfRangeTest.java | 4 +-
.../cassandra/db/ReadCommandVerbHandlerTest.java | 2 +-
.../org/apache/cassandra/db/ReadResponseTest.java | 26 +-
.../db/SSTableAndMemTableDigestMatchTest.java | 2 +-
.../db/lifecycle/RealTransactionsTest.java | 2 +
.../net/MessageSerializationPropertyTest.java | 16 -
.../cassandra/replication/CoordinatorLogTest.java | 8 +-
.../apache/cassandra/replication/OffsetsTest.java | 152 ++--
.../service/reads/AbstractReadResponseTest.java | 10 +-
.../cassandra/service/reads/DataResolverTest.java | 7 +-
.../service/reads/DigestResolverTest.java | 1 -
.../cassandra/service/reads/ReadExecutorTest.java | 2 +-
.../reads/repair/InstrumentedReadRepair.java | 3 +-
.../reads/repair/RepairedDataVerifierTest.java | 6 +-
.../service/reads/repair/TestableReadRepair.java | 7 +-
94 files changed, 4478 insertions(+), 3364 deletions(-)
copy src/java/org/apache/cassandra/db/{ReadCommandVerbHandler.java =>
AbstractReadCommandVerbHandler.java} (67%)
copy
src/java/org/apache/cassandra/db/partitions/{AbstractUnfilteredPartitionIterator.java
=> AbstractPartitionIterator.java} (79%)
copy src/java/org/apache/cassandra/db/partitions/{BTreePartitionUpdater.java
=> SimpleBTreePartition.java} (52%)
copy src/java/org/apache/cassandra/db/rows/{AbstractUnfilteredRowIterator.java
=> AbstractRowIterator.java} (54%)
create mode 100644
src/java/org/apache/cassandra/replication/Log2OffsetsMap.java
rename src/java/org/apache/cassandra/service/reads/{untracked =>
}/DataResolver.java (94%)
rename src/java/org/apache/cassandra/service/reads/{untracked =>
}/DigestResolver.java (82%)
delete mode 100644
src/java/org/apache/cassandra/service/reads/IReadResponse.java
create mode 100644
src/java/org/apache/cassandra/service/reads/tracked/AbstractPartialTrackedRead.java
create mode 100644
src/java/org/apache/cassandra/service/reads/tracked/PartialTrackedRangeRead.java
create mode 100644
src/java/org/apache/cassandra/service/reads/tracked/PartialTrackedRead.java
create mode 100644
src/java/org/apache/cassandra/service/reads/tracked/PartialTrackedSinglePartitionRead.java
delete mode 100644
src/java/org/apache/cassandra/service/reads/tracked/ReadReconciliations.java
create mode 100644
src/java/org/apache/cassandra/service/reads/tracked/TrackedDataResponse.java
create mode 100644
src/java/org/apache/cassandra/service/reads/tracked/TrackedLocalReadCoordinator.java
create mode 100644
src/java/org/apache/cassandra/service/reads/tracked/TrackedLocalReads.java
create mode 100644
src/java/org/apache/cassandra/service/reads/tracked/TrackedRead.java
delete mode 100644
src/java/org/apache/cassandra/service/reads/tracked/TrackedReadReconciliation.java
delete mode 100644
src/java/org/apache/cassandra/service/reads/tracked/TrackedReadResponse.java
delete mode 100644
src/java/org/apache/cassandra/service/reads/tracked/TrackedResolver.java
create mode 100644
src/java/org/apache/cassandra/service/reads/tracked/TrackedSummaryResponse.java
delete mode 100644
src/java/org/apache/cassandra/service/reads/untracked/UntrackedReadRepair.java
delete mode 100644
src/java/org/apache/cassandra/service/reads/untracked/UntrackedResolver.java
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org
For additional commands, e-mail: commits-h...@cassandra.apache.org
