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 698a1ea845 Refactor CommandsForKey for efficiency, and to support
transitive dependency elision
add 85411ebcdd 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, 2585 insertions(+), 2254 deletions(-)
create mode 100644
src/java/org/apache/cassandra/service/consensus/TransactionalMode.java
create mode 100644
src/java/org/apache/cassandra/service/consensus/migration/ConsensusMigratedAt.java
create mode 100644
src/java/org/apache/cassandra/service/consensus/migration/ConsensusMigrationRepairResult.java
create mode 100644
src/java/org/apache/cassandra/service/consensus/migration/ConsensusMigrationRepairType.java
create mode 100644
src/java/org/apache/cassandra/service/consensus/migration/ConsensusMigrationState.java
create mode 100644
src/java/org/apache/cassandra/service/consensus/migration/ConsensusMigrationTarget.java
create mode 100644
src/java/org/apache/cassandra/service/consensus/migration/ConsensusTableMigration.java
delete mode 100644
src/java/org/apache/cassandra/service/consensus/migration/ConsensusTableMigrationState.java
create mode 100644
src/java/org/apache/cassandra/service/consensus/migration/TableMigrationState.java
create mode 100644
src/java/org/apache/cassandra/service/consensus/migration/TransactionalMigrationFromMode.java
delete mode 100644
src/java/org/apache/cassandra/tcm/ownership/AccordTables.java
delete mode 100644
src/java/org/apache/cassandra/tcm/transformations/AddAccordTable.java
delete mode 100644
src/java/org/apache/cassandra/tcm/transformations/SetConsensusMigrationTargetProtocol.java
delete mode 100644
test/distributed/org/apache/cassandra/distributed/test/tcm/AccordAddTableTest.java
create mode 100644
test/unit/org/apache/cassandra/schema/TransactionalConfigSchemaTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
