This is an automated email from the ASF dual-hosted git repository. aweisberg pushed a change to branch cep-15-accord in repository https://gitbox.apache.org/repos/asf/cassandra.git
from 85411ebcdd CEP-15: (C*) per-table transactional configuration add abe37a4d0e Revert "CEP-15: (C*) per-table transactional configuration" No new revisions were added by this update. Summary of changes: .../org/apache/cassandra/config/AccordSpec.java | 20 - src/java/org/apache/cassandra/config/Config.java | 115 +++ .../cassandra/config/DatabaseDescriptor.java | 43 +- .../cassandra/cql3/statements/CQL3CasRequest.java | 5 +- .../cql3/statements/TransactionStatement.java | 15 +- .../statements/schema/AlterSchemaStatement.java | 4 - .../statements/schema/AlterTableStatement.java | 41 - .../statements/schema/CreateTableStatement.java | 11 - .../cql3/statements/schema/TableAttributes.java | 14 +- .../org/apache/cassandra/db/SystemKeyspace.java | 4 +- .../db/streaming/CassandraStreamReceiver.java | 2 +- .../apache/cassandra/repair/AccordRepairJob.java | 2 +- .../cassandra/repair/CassandraRepairJob.java | 2 +- .../org/apache/cassandra/repair/RepairResult.java | 2 +- .../org/apache/cassandra/repair/RepairSession.java | 4 +- .../apache/cassandra/schema/DistributedSchema.java | 15 - .../org/apache/cassandra/schema/TableMetadata.java | 15 - .../org/apache/cassandra/schema/TableParams.java | 61 +- .../org/apache/cassandra/service/StorageProxy.java | 84 +- .../apache/cassandra/service/StorageService.java | 25 +- .../cassandra/service/StorageServiceMBean.java | 4 + .../cassandra/service/accord/AccordService.java | 46 +- .../cassandra/service/accord/AccordTopology.java | 78 +- .../cassandra/service/accord/IAccordService.java | 68 +- .../accord/interop/AccordInteropExecution.java | 8 +- .../cassandra/service/accord/txn/TxnQuery.java | 6 + .../service/consensus/TransactionalMode.java | 140 ---- .../migration/ConsensusKeyMigrationState.java | 7 +- .../consensus/migration/ConsensusMigratedAt.java | 70 -- .../migration/ConsensusMigrationRepairResult.java | 50 -- .../migration/ConsensusMigrationRepairType.java | 55 -- .../migration/ConsensusMigrationState.java | 256 ------ .../migration/ConsensusMigrationTarget.java | 59 -- .../migration/ConsensusRequestRouter.java | 99 +-- .../migration/ConsensusTableMigration.java | 336 -------- .../migration/ConsensusTableMigrationState.java | 907 +++++++++++++++++++++ .../consensus/migration/TableMigrationState.java | 360 -------- .../migration/TransactionalMigrationFromMode.java | 83 -- .../cassandra/service/paxos/PaxosPrepare.java | 3 +- .../service/reads/repair/BlockingReadRepair.java | 8 +- .../org/apache/cassandra/streaming/StreamPlan.java | 8 +- .../org/apache/cassandra/tcm/ClusterMetadata.java | 64 +- .../org/apache/cassandra/tcm/MetadataKeys.java | 2 + .../org/apache/cassandra/tcm/Transformation.java | 15 +- .../cassandra/tcm/compatibility/GossipHelper.java | 6 +- .../cassandra/tcm/ownership/AccordTables.java | 109 +++ .../tcm/transformations/AddAccordTable.java | 90 ++ .../cassandra/tcm/transformations/AlterSchema.java | 90 +- .../BeginConsensusMigrationForTableAndRange.java | 42 +- ...beFinishConsensusMigrationForTableAndRange.java | 67 +- .../SetConsensusMigrationTargetProtocol.java | 131 +++ src/java/org/apache/cassandra/tools/NodeTool.java | 1 + .../tools/nodetool/ConsensusMigrationAdmin.java | 23 + .../cassandra/distributed/test/ReadRepairTest.java | 153 ++-- .../distributed/test/ShortReadProtectionTest.java | 60 +- .../test/accord/AccordBootstrapTest.java | 4 +- .../distributed/test/accord/AccordCQLTest.java | 224 ++--- .../test/accord/AccordFeatureFlagTest.java | 67 +- .../test/accord/AccordInteropReadTest.java | 9 +- .../test/accord/AccordInteroperabilityTest.java | 5 +- .../distributed/test/accord/AccordMetricsTest.java | 5 +- .../test/accord/AccordMigrationTest.java | 167 +--- .../test/accord/AccordSimpleFastPathTest.java | 3 +- .../distributed/test/accord/AccordTestBase.java | 9 +- .../distributed/test/accord/NewSchemaTest.java | 2 +- .../test/log/ClusterMetadataTestHelper.java | 4 + .../distributed/test/tcm/AccordAddTableTest.java | 80 ++ .../apache/cassandra/audit/AuditLoggerTest.java | 2 +- .../org/apache/cassandra/auth/TxnAuthTest.java | 2 +- .../config/DatabaseDescriptorRefTest.java | 3 - .../cassandra/cql3/NodeLocalConsistencyTest.java | 2 +- .../cassandra/cql3/PreparedStatementsTest.java | 94 +-- .../cql3/statements/DescribeStatementTest.java | 2 - .../apache/cassandra/db/SchemaCQLHelperTest.java | 2 - .../apache/cassandra/locator/MetaStrategyTest.java | 4 +- .../org/apache/cassandra/repair/FuzzTestBase.java | 6 +- .../cassandra/schema/FastPathSchemaTest.java | 14 +- .../schema/TransactionalConfigSchemaTest.java | 95 --- .../service/accord/AccordCommandStoreTest.java | 6 +- .../service/accord/AccordCommandTest.java | 2 +- .../accord/AccordConfigurationServiceTest.java | 2 +- .../service/accord/AccordReadRepairTest.java | 6 +- .../service/accord/AccordTopologyTest.java | 14 +- .../service/accord/api/AccordKeyTest.java | 4 +- .../service/accord/async/AsyncLoaderTest.java | 2 +- .../service/accord/async/AsyncOperationTest.java | 2 +- .../accord/serializers/CommandSerializersTest.java | 2 +- .../serializers/CommandsForKeySerializerTest.java | 2 +- .../service/accord/txn/AccordUpdateTest.java | 2 +- .../tcm/ClusterMetadataTransformationTest.java | 2 + 90 files changed, 2254 insertions(+), 2585 deletions(-) delete mode 100644 src/java/org/apache/cassandra/service/consensus/TransactionalMode.java delete mode 100644 src/java/org/apache/cassandra/service/consensus/migration/ConsensusMigratedAt.java delete mode 100644 src/java/org/apache/cassandra/service/consensus/migration/ConsensusMigrationRepairResult.java delete mode 100644 src/java/org/apache/cassandra/service/consensus/migration/ConsensusMigrationRepairType.java delete mode 100644 src/java/org/apache/cassandra/service/consensus/migration/ConsensusMigrationState.java delete mode 100644 src/java/org/apache/cassandra/service/consensus/migration/ConsensusMigrationTarget.java delete mode 100644 src/java/org/apache/cassandra/service/consensus/migration/ConsensusTableMigration.java create mode 100644 src/java/org/apache/cassandra/service/consensus/migration/ConsensusTableMigrationState.java delete mode 100644 src/java/org/apache/cassandra/service/consensus/migration/TableMigrationState.java delete mode 100644 src/java/org/apache/cassandra/service/consensus/migration/TransactionalMigrationFromMode.java create mode 100644 src/java/org/apache/cassandra/tcm/ownership/AccordTables.java create mode 100644 src/java/org/apache/cassandra/tcm/transformations/AddAccordTable.java create mode 100644 src/java/org/apache/cassandra/tcm/transformations/SetConsensusMigrationTargetProtocol.java create mode 100644 test/distributed/org/apache/cassandra/distributed/test/tcm/AccordAddTableTest.java delete mode 100644 test/unit/org/apache/cassandra/schema/TransactionalConfigSchemaTest.java --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org