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