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
