This is an automated email from the ASF dual-hosted git repository.
bdeggleston pushed a change to branch cep-15-accord
in repository https://gitbox.apache.org/repos/asf/cassandra.git
from 41a2160e1c Fix TombstoneCountWarningTest
add 38f355ce7f Schema based accord fast path configuration
No new revisions were added by this update.
Summary of changes:
conf/cassandra.yaml | 3 +
modules/accord | 2 +-
.../org/apache/cassandra/config/AccordSpec.java | 2 +
.../cassandra/config/DatabaseDescriptor.java | 10 +
.../cql3/statements/TransactionStatement.java | 2 +-
.../cql3/statements/schema/KeyspaceAttributes.java | 27 +-
.../cql3/statements/schema/TableAttributes.java | 14 +
.../db/streaming/CassandraStreamReceiver.java | 2 +-
.../org/apache/cassandra/dht/AccordSplitter.java | 7 +-
.../org/apache/cassandra/dht/BootStrapper.java | 6 +-
.../org/apache/cassandra/dht/RangeStreamer.java | 25 +-
.../apache/cassandra/locator/ReplicaLayout.java | 5 +-
.../org/apache/cassandra/locator/ReplicaPlans.java | 31 +-
.../apache/cassandra/repair/AccordRepairJob.java | 4 +-
.../schema/DistributedMetadataLogKeyspace.java | 3 +-
.../apache/cassandra/schema/KeyspaceMetadata.java | 13 +-
.../apache/cassandra/schema/KeyspaceParams.java | 47 +-
.../apache/cassandra/schema/SchemaKeyspace.java | 31 +-
.../org/apache/cassandra/schema/TableMetadata.java | 7 +
.../org/apache/cassandra/schema/TableParams.java | 33 +-
src/java/org/apache/cassandra/service/Rebuild.java | 13 +-
.../org/apache/cassandra/service/StorageProxy.java | 6 +-
.../apache/cassandra/service/StorageService.java | 19 +-
.../cassandra/service/StorageServiceMBean.java | 1 +
.../service/accord/AccordCommandStores.java | 9 +-
.../service/accord/AccordConfigurationService.java | 12 +-
.../service/accord/AccordEndpointMapper.java | 15 +-
.../cassandra/service/accord/AccordFastPath.java | 262 ++++++
.../service/accord/AccordFastPathCoordinator.java | 340 ++++++++
.../service/accord/AccordFetchCoordinator.java | 11 +-
.../cassandra/service/accord/AccordKeyspace.java | 6 +-
.../service/accord/AccordObjectSizes.java | 7 +-
.../cassandra/service/accord/AccordService.java | 26 +-
.../cassandra/service/accord/AccordTopology.java | 277 +++++++
.../service/accord/AccordTopologyUtils.java | 162 ----
.../service/accord/CommandsForRanges.java | 17 +-
.../cassandra/service/accord/EndpointMapping.java | 4 +-
.../cassandra/service/accord/IAccordService.java | 57 +-
.../cassandra/service/accord/TokenRange.java | 15 +-
.../service/accord/api/AccordRoutableKey.java | 21 +-
.../service/accord/api/AccordRoutingKey.java | 65 +-
.../cassandra/service/accord/api/PartitionKey.java | 28 +-
.../service/accord/fastpath/FastPathStrategy.java | 183 +++++
.../fastpath/InheritKeyspaceFastPathStrategy.java} | 45 +-
.../fastpath/ParameterizedFastPathStrategy.java | 375 +++++++++
.../accord/fastpath/SimpleFastPathStrategy.java | 87 ++
.../accord/interop/AccordInteropExecution.java | 5 +-
.../accord/serializers/TopologySerializers.java | 40 +-
.../cassandra/service/accord/txn/TxnNamedRead.java | 2 +-
.../cassandra/service/accord/txn/TxnQuery.java | 2 +-
.../migration/ConsensusKeyMigrationState.java | 4 +-
.../service/reads/AbstractReadExecutor.java | 1 +
.../cassandra/service/reads/ReadCoordinator.java | 5 +-
.../service/reads/range/RangeCommands.java | 6 +-
.../service/reads/range/ReplicaPlanIterator.java | 6 +-
.../service/reads/range/ReplicaPlanMerger.java | 7 +-
.../org/apache/cassandra/streaming/StreamPlan.java | 29 +
.../org/apache/cassandra/tcm/ClusterMetadata.java | 109 ++-
.../org/apache/cassandra/tcm/MetadataKeys.java | 6 +-
.../org/apache/cassandra/tcm/Transformation.java | 19 +-
.../cassandra/tcm/compatibility/GossipHelper.java | 12 +-
.../cassandra/tcm/ownership/AccordKeyspaces.java | 108 ---
.../cassandra/tcm/ownership/AccordTables.java | 109 +++
.../org/apache/cassandra/tcm/sequences/Move.java | 13 +-
.../cassandra/tcm/serialization/Version.java | 1 +
...{AddAccordKeyspace.java => AddAccordTable.java} | 49 +-
.../transformations/ReconfigureAccordFastPath.java | 97 +++
.../cms/PrepareCMSReconfiguration.java | 3 +-
src/java/org/apache/cassandra/tools/NodeProbe.java | 8 +-
src/java/org/apache/cassandra/tools/NodeTool.java | 2 +-
.../cassandra/distributed/test/ReadRepairTest.java | 3 +-
.../distributed/test/ShortReadProtectionTest.java | 8 +-
.../test/accord/AccordBootstrapTest.java | 4 +-
.../distributed/test/accord/AccordCQLTest.java | 889 +++++++++++----------
.../test/accord/AccordIntegrationTest.java | 20 +-
.../test/accord/AccordInteroperabilityTest.java | 14 +-
.../distributed/test/accord/AccordMetricsTest.java | 10 +-
.../test/accord/AccordMigrationTest.java | 22 +-
.../test/accord/AccordSimpleFastPathTest.java | 131 +++
.../distributed/test/accord/AccordTestBase.java | 14 +-
.../test/log/ClusterMetadataTestHelper.java | 12 +-
.../test/AccordJournalSimulationTest.java | 6 +-
.../cql3/statements/DescribeStatementTest.java | 13 +-
.../apache/cassandra/db/SchemaCQLHelperTest.java | 3 +
.../org/apache/cassandra/dht/BootStrapperTest.java | 3 +-
.../apache/cassandra/dht/PartitionerTestCase.java | 11 +-
.../locator/AssureSufficientLiveNodesTest.java | 16 +-
.../apache/cassandra/locator/MetaStrategyTest.java | 6 +-
.../cassandra/schema/FastPathSchemaTest.java | 121 +++
.../service/accord/AccordCommandStoreTest.java | 5 +-
.../service/accord/AccordCommandTest.java | 2 +-
.../accord/AccordConfigurationServiceTest.java | 14 +-
.../accord/AccordFastPathCoordinatorTest.java | 253 ++++++
.../service/accord/AccordKeyspaceTest.java | 16 +-
.../service/accord/AccordReadRepairTest.java | 17 +-
.../service/accord/AccordSyncPropagatorTest.java | 9 +-
.../cassandra/service/accord/AccordTestUtils.java | 28 +-
.../service/accord/AccordTopologyTest.java | 103 ++-
.../service/accord/CommandsForRangesTest.java | 5 +-
.../service/accord/SimpleAccordEndpointMapper.java | 4 +-
.../service/accord/api/AccordKeyTest.java | 36 +-
.../accord/fastpath/FastPathParsingTest.java | 109 +++
.../ParameterizedFastPathStrategyTest.java | 153 ++++
.../SimpleFastPathStrategyTest.java} | 23 +-
.../accord/serializers/CommandSerializersTest.java | 2 +-
.../service/accord/txn/AbstractKeySortedTest.java | 2 +-
.../cassandra/service/reads/DataResolverTest.java | 2 +-
.../reads/range/RangeCommandIteratorTest.java | 10 +-
.../service/reads/range/RangeCommandsTest.java | 6 +-
.../reads/range/ReplicaPlanIteratorTest.java | 4 +-
.../service/reads/range/ReplicaPlanMergerTest.java | 4 +-
.../reads/repair/AbstractReadRepairTest.java | 2 +-
.../tcm/ClusterMetadataTransformationTest.java | 15 +-
.../apache/cassandra/utils/AccordGenerators.java | 42 +-
114 files changed, 3911 insertions(+), 1241 deletions(-)
create mode 100644
src/java/org/apache/cassandra/service/accord/AccordFastPath.java
create mode 100644
src/java/org/apache/cassandra/service/accord/AccordFastPathCoordinator.java
create mode 100644
src/java/org/apache/cassandra/service/accord/AccordTopology.java
delete mode 100644
src/java/org/apache/cassandra/service/accord/AccordTopologyUtils.java
create mode 100644
src/java/org/apache/cassandra/service/accord/fastpath/FastPathStrategy.java
copy
src/java/org/apache/cassandra/service/{reads/NeverSpeculativeRetryPolicy.java
=> accord/fastpath/InheritKeyspaceFastPathStrategy.java} (50%)
create mode 100644
src/java/org/apache/cassandra/service/accord/fastpath/ParameterizedFastPathStrategy.java
create mode 100644
src/java/org/apache/cassandra/service/accord/fastpath/SimpleFastPathStrategy.java
delete mode 100644
src/java/org/apache/cassandra/tcm/ownership/AccordKeyspaces.java
create mode 100644
src/java/org/apache/cassandra/tcm/ownership/AccordTables.java
rename
src/java/org/apache/cassandra/tcm/transformations/{AddAccordKeyspace.java =>
AddAccordTable.java} (53%)
create mode 100644
src/java/org/apache/cassandra/tcm/transformations/ReconfigureAccordFastPath.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/accord/AccordSimpleFastPathTest.java
create mode 100644
test/unit/org/apache/cassandra/schema/FastPathSchemaTest.java
create mode 100644
test/unit/org/apache/cassandra/service/accord/AccordFastPathCoordinatorTest.java
create mode 100644
test/unit/org/apache/cassandra/service/accord/fastpath/FastPathParsingTest.java
create mode 100644
test/unit/org/apache/cassandra/service/accord/fastpath/ParameterizedFastPathStrategyTest.java
copy
test/unit/org/apache/cassandra/service/accord/{serializers/TopologySerializersTest.java
=> fastpath/SimpleFastPathStrategyTest.java} (54%)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org
For additional commands, e-mail: commits-h...@cassandra.apache.org
