This is an automated email from the ASF dual-hosted git repository.
samt pushed a change to branch cep-21-tcm
in repository https://gitbox.apache.org/repos/asf/cassandra.git
omit 2d133ba464 TMP - use bundled version of harry
omit 11e8ded97b [CEP-21] Bulk update of unit and dtests
omit e2036cd719 [CEP-21] Test / build config changes
omit 85748281f4 [CEP-21] Modify CassandraDaemon
omit 4892a4e0ea [CEP-21] Update snitches to use Directory
omit 6438a5f17b [CEP-21] Upgrade support
omit e7d451fd6b [CEP-21] Option to record thread creation stacktrace
omit bb615495ba [CEP-21] Add missing implementations to concurrent utils
omit 7bda86e1fe [CEP-21] New nodetool commands
omit 9a1546b089 [CEP-21] Restore operation mode reporting (7/7)
omit f528d235c8 [CEP-21] Remove TokenMetadata (6/7)
omit 205331198f [CEP-21] Fix misc compilation errors (5/7)
omit da5b8ec9ce [CEP-21] Update ColumnFamilyStore (4/7)
omit ad7edf5331 [CEP-21] Consistent read/write path (3/7)
omit 8425d3177d [CEP-21] Placement and ownership related changes (2/7)
omit 6fcff5b04e [CEP-21] Major changes to StorageService to remove TMD and
Gossip (1/7)
omit d4d35a7d79 [CEP-21] Replace fake initial implementation of CMS
membership
omit 5a09d94419 [CEP-21] Start to remove and deprecate gossip functionality
omit ee17642571 [CEP-21] Initial transforms for modifying ownership
omit 57ad145f19 [CEP-21] Produce placements equivalent to current
replication strategies
omit 2434132cc7 [CEP-21] Add basics of ownership and data placement
omit 35910f2425 [CEP-21] Add rudimentary cluster membership to TCM
omit 56d289b4fb [CEP-21] Include current epoch in internode header
omit 728a9d9a07 [CEP-21] Move schema management to TCM
omit 7b6b04a8bf [CEP-21] Add distributed metadata log
add 8df69c8016 Fix the ordering of sstables when running sstableupgrade
tool
add 58d06d34ab Merge branch 'cassandra-3.0' into cassandra-3.11
add 5104008db9 Merge branch 'cassandra-3.11' into cassandra-4.0
add deb8abd2fd Merge branch 'cassandra-4.0' into cassandra-4.1
add d1ba381d96 Merge branch 'cassandra-4.1' into trunk
add 5c51f05dab Remove JAVA8/JAVA11_HOME from circle configs
add fb95112427 Upgrade maven-shade-plugin to 3.4.1 to fix shaded dtest JAR
build
add 8d91b469af Prepare debian changelog for 4.1.1
add 034e009e93 Merge branch 'cassandra-4.1' into trunk
add 4734dfc503 Extend implicit allow-filtering for virtual tables to
clustering columns
add a76286795f Add system_views.max_sstable_size and
system_views.max_sstable_duration tables
add d5b1483703 Incompatible file system thrown while running Simulator
add 92c90cd4ef Merge branch 'cassandra-4.1' into trunk
add 58a3b12508 Remove DateTieredCompactionStrategy
add 3eb605b4db Remove deprecated CQL functions dateOf and unixTimestampOf
add 0dea9c268a CircleCI config J17 + J11 patch by Ekaterina Dimitrova;
reviewed by Michael Semb Wever and Brandon Williams for CASSANDRA-18247
add f6a04ca81f Fix RepairJob unnecessarily reporting cancellation error
add 955cf156c8 Merge branch 'cassandra-3.0' into cassandra-3.11
add 2974810607 Merge branch 'cassandra-3.11' into cassandra-4.0
add fb9699c231 Merge branch 'cassandra-4.0' into cassandra-4.1
add 11ea405952 Merge branch 'cassandra-4.1' into trunk
add 3021c33cab Increment version to 4.1.2
add 0136374545 Merge branch 'cassandra-4.1' into trunk
add 592cbeaab0 Remove org.apache.cassandra.hadoop code
add eee211fdbb Update OpenHFT dependencies (chronicle-queue,
chronicle-core, chronicle-bytes, chronicle-wire, chronicle-threads)
add fc9efd6357 Add virtual table system_views.snapshots
add 4138dd697a Fix trunk CHANGES.txt
add a6f8dd10cd Remove six and Py2SaferScanner merge cruft
add 080ad4963c Merge branch 'cassandra-4.1' into trunk
add 70b95d8098 Restore COPY ... TO STDOUT behavior in cqlsh
add b4d4cf716b Merge branch 'cassandra-4.1' into trunk
add de1ff6d4d1 Fix nodetool/sjk hh, Java17 patch by Ekaterina Dimitrova,
reviewed by Brandon Williams for CASSANDRA-18242
add 2e2a49fcdc CEP-20: Dynamic Data Masking
add 7c2f97cd29 Do not submit hints when hinted_handoff_enabled=false
add ffe669106b Merge branch 'cassandra-4.1' into trunk
add 4444721b6d Provide summary of failed SessionInfo's in
StreamResultFuture
add 4ac89e6451 Fix NPE when loading snapshots and data directory is one
directory from root
add eca75a42ef Merge branch 'cassandra-4.1' into trunk
add 6f401a8725 Return snapshots with dots in their name in nodetool
listsnapshots
add 6a5f84d0f4 Merge branch 'cassandra-4.1' into trunk
add f352f2b637 Notify the corresponding JIRA issue as soon as the PR is
raised
add 11b84d2ef2 Merge branch 'cassandra-3.0' into cassandra-3.11
add 5b877b9d2b Merge branch 'cassandra-3.11' into cassandra-4.0
add 5fa2f87741 Merge branch 'cassandra-4.0' into cassandra-4.1
add 297825773a Merge branch 'cassandra-4.1' into trunk
add 2f8d11335e Remove asf.yaml from non-trunk branches
add c4535a2e2a Merge branch 'cassandra-3.0' into cassandra-3.11
add 5f61645778 Merge branch 'cassandra-3.11' into cassandra-4.0
add 780f8b94ff Merge branch 'cassandra-4.0' into cassandra-4.1
add 549bf38a07 Merge branch 'cassandra-4.1' into trunk
add e98258a132 Upgrade checkstyle to 10.8.1 for j11 and 8.45.1 for j8
add f96659c530 Save host id to system.local and flush immediately after
startup
add ee586b53c2 Merge branch 'cassandra-3.0' into cassandra-3.11
add 4b9c18235a Merge branch 'cassandra-3.11' into cassandra-4.0
add f8dd1931ee Merge branch 'cassandra-4.0' into cassandra-4.1
add e07b8dfe8d Merge branch 'cassandra-4.1' into trunk
add 14936d0bd3 Merge branch 'cassandra-4.0' into cassandra-4.1
add 853ae8c840 Avoid loading the preferred IP for BulkLoader streaming
add 03806f95e4 Merge branch 'cassandra-4.0' into cassandra-4.1
add 9f078090e9 Merge branch 'cassandra-4.1' into trunk
add 4effa4efbe ninja-fix CHANGES.txt remove merge sections
new 3f20c5198b [CEP-21] Add distributed metadata log
new bdcfa6c820 [CEP-21] Move schema management to TCM
new 62d72284f7 [CEP-21] Include current epoch in internode header
new 363b34c0fb [CEP-21] Add rudimentary cluster membership to TCM
new 9b8bd95176 [CEP-21] Add basics of ownership and data placement
new 80b97e27e7 [CEP-21] Produce placements equivalent to current
replication strategies
new 0b179ce0ab [CEP-21] Initial transforms for modifying ownership
new c232bcb57a [CEP-21] Start to remove and deprecate gossip functionality
new c4d8742dbb [CEP-21] Replace fake initial implementation of CMS
membership
new 70d82258ab [CEP-21] Major changes to StorageService to remove TMD and
Gossip (1/7)
new 35354a6779 [CEP-21] Placement and ownership related changes (2/7)
new dca3895684 [CEP-21] Consistent read/write path (3/7)
new 2eac1151bd [CEP-21] Update ColumnFamilyStore (4/7)
new 9c496e842d [CEP-21] Fix misc compilation errors (5/7)
new a93bb228d0 [CEP-21] Remove TokenMetadata (6/7)
new f9f5faa1a7 [CEP-21] Restore operation mode reporting (7/7)
new b18d21d930 [CEP-21] New nodetool commands
new 788ea747ce [CEP-21] Add missing implementations to concurrent utils
new c032fd62d0 [CEP-21] Option to record thread creation stacktrace
new bde3d39daf [CEP-21] Upgrade support
new c61da0c4a3 [CEP-21] Update snitches to use Directory
new af26ae2d6d [CEP-21] Modify CassandraDaemon
new 56c68111aa [CEP-21] Test / build config changes
new 0e323c96fb [CEP-21] Bulk update of unit and dtests
new 06fd61c8b4 TMP - use bundled version of harry
new b4ee46eb99 Circle config
new a3564a3faf [CEP-21] Correctly represent bootstrapping nodes in
StorageService
new fde56f2531 [CEP-21] Fix nodetool ring and effective ownership
new 0a1f72bf68 [CEP-21] Secondary indexes should not be rebuilt on restart
new eabc558d0f [CEP-21] Re-enable stdout/sterr redirection at startup
new 086fbe30cd [CEP-21] Ensure that global log replication factor is
maintained after decommission
new e4fc7e9d1b [CEP-21] Dereference TableMetadata in simple partition
builder
new 91829d2069 [CEP-21] During multi step operations, defer token map
update until completion of final step
new 37edaf238b [CEP-21] Add debounce to log replay
new 0e43dae383 [CEP-21] Always populate local gossip state at startup
new 09a9e089bf [CEP-21] Improve seedlist inspection at startup
new 6ca34e62f2 [CEP-21] Various fixes to in-jvm dtests
new 890e131735 [CEP-21] Always use Paxos.v2 for global log reads/writes
new 00d78e56ba [CEP-21] Remove paranoid check during SRPP
new 8fd47e605f [CEP-21] Implement retries for log replay on CMS members
new 80983b3cbb [CEP-21] Improve support for start/end tokens in nodetool
rebuild
new 5a5568eb60 [CEP-21] Add invalid routing exception
new 306afbb8ff [CEP-21] Fix (re)building MVs
new 090f7c3fb4 [CEP-21] Implement multi-dc placement simulator for NTS
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (2d133ba464)
\
N -- N -- N refs/heads/cep-21-tcm (090f7c3fb4)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 44 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.asf.yaml | 3 +
.build/build-resolver.xml | 6 +
.build/cassandra-build-deps-template.xml | 4 -
.build/cassandra-deps-template.xml | 44 +-
.build/parent-pom-template.xml | 145 +-
.circleci/config.yml | 434 +-
.circleci/config.yml.FREE | 190 -
.circleci/config.yml.PAID | 190 -
.circleci/{config.yml => config_11_and_17.yml} | 8010 ++++++++------------
.../{config.yml => config_11_and_17.yml.FREE} | 8010 ++++++++------------
.../{config.yml.PAID => config_11_and_17.yml.PAID} | 7648 ++++++++-----------
.circleci/config_template.yml | 2 -
.circleci/config_template.yml.PAID.patch | 68 +-
..._template.yml => config_template_11_and_17.yml} | 2110 +++---
...ch => config_template_11_and_17.yml.PAID.patch} | 325 +-
.circleci/generate_11_and_17.sh | 306 +
.circleci/readme.md | 54 +-
CHANGES.txt | 76 +-
NEWS.txt | 18 +-
README.asc | 2 +-
build.xml | 13 +-
checkstyle.xml | 2 +-
conf/cassandra.yaml | 8 +
conf/jvm11-server.options | 1 +
conf/jvm17-clients.options | 1 +
conf/jvm17-server.options | 1 +
doc/cql3/CQL.textile | 41 +-
doc/modules/cassandra/examples/BNF/alter_table.bnf | 5 +-
.../cassandra/examples/BNF/create_table.bnf | 5 +-
.../examples/BNF/grant_permission_statement.bnf | 2 +-
.../cassandra/examples/CQL/ddm_alter_mask.cql | 1 +
.../cassandra/examples/CQL/ddm_create_table.cql | 5 +
.../examples/CQL/ddm_create_table_with_udf.cql | 11 +
.../cassandra/examples/CQL/ddm_create_users.cql | 6 +
.../cassandra/examples/CQL/ddm_drop_mask.cql | 1 +
.../cassandra/examples/CQL/ddm_insert_data.cql | 2 +
.../cassandra/examples/CQL/ddm_revoke_unmask.cql | 1 +
.../CQL/ddm_select_with_masked_columns.cql | 6 +
.../examples/CQL/ddm_select_with_select_masked.cql | 8 +
.../CQL/ddm_select_with_unmask_permission.cql | 7 +
.../CQL/ddm_select_without_select_masked.cql | 6 +
.../CQL/ddm_select_without_unmask_permission.cql | 7 +
.../examples/CQL/select_with_mask_functions.cql | 15 +
doc/modules/cassandra/nav.adoc | 1 +
doc/modules/cassandra/pages/cql/appendices.adoc | 3 +
doc/modules/cassandra/pages/cql/changes.adoc | 8 +
.../cassandra/pages/cql/cql_singlefile.adoc | 40 +-
doc/modules/cassandra/pages/cql/ddl.adoc | 2 -
.../cassandra/pages/cql/dynamic_data_masking.adoc | 178 +
doc/modules/cassandra/pages/cql/functions.adoc | 67 +-
doc/modules/cassandra/pages/cql/index.adoc | 1 +
doc/modules/cassandra/pages/cql/security.adoc | 14 +
doc/modules/cassandra/pages/new/virtualtables.adoc | 4 +-
.../pages/operating/compaction/index.adoc | 12 +-
.../cassandra/pages/operating/virtualtables.adoc | 4 +-
.../cassandra/partials/masking_functions.adoc | 61 +
pylib/cqlshlib/copyutil.py | 7 +-
pylib/cqlshlib/cql3handling.py | 17 +-
pylib/cqlshlib/cqlhandling.py | 1 -
pylib/cqlshlib/saferscanner.py | 3 +-
pylib/cqlshlib/test/test_cqlsh_completion.py | 40 +-
relocate-dependencies.pom | 2 +-
src/antlr/Cql.g | 1 +
src/antlr/Lexer.g | 4 +
src/antlr/Parser.g | 31 +-
.../apache/cassandra/audit/AuditLogOptions.java | 4 +-
.../org/apache/cassandra/audit/BinAuditLogger.java | 4 +-
.../cassandra/auth/CassandraRoleManager.java | 2 +-
.../org/apache/cassandra/auth/DataResource.java | 12 +-
src/java/org/apache/cassandra/auth/Permission.java | 8 +-
.../apache/cassandra/batchlog/BatchlogManager.java | 2 +-
src/java/org/apache/cassandra/config/Config.java | 7 +-
.../cassandra/config/DatabaseDescriptor.java | 30 +-
.../org/apache/cassandra/cql3/QueryProcessor.java | 8 +-
.../apache/cassandra/cql3/UntypedResultSet.java | 4 +-
.../cassandra/cql3/functions/FunctionResolver.java | 35 +-
.../apache/cassandra/cql3/functions/TimeFcts.java | 55 -
.../cql3/functions/masking/ColumnMask.java | 393 +
.../functions/masking/DefaultMaskingFunction.java | 25 +-
.../functions/masking/HashMaskingFunction.java | 31 +-
.../cql3/functions/masking/MaskingFunction.java | 31 +
.../functions/masking/NullMaskingFunction.java | 15 +-
.../functions/masking/PartialMaskingFunction.java | 65 +-
.../functions/masking/ReplaceMaskingFunction.java | 21 +-
.../cql3/restrictions/StatementRestrictions.java | 2 +-
.../cassandra/cql3/selection/ResultSetBuilder.java | 15 +-
.../cassandra/cql3/selection/Selectable.java | 13 +-
.../apache/cassandra/cql3/selection/Selection.java | 26 +-
.../apache/cassandra/cql3/selection/Selector.java | 12 +-
.../cql3/selection/SelectorFactories.java | 2 +-
.../cassandra/cql3/selection/SimpleSelector.java | 31 +-
.../cql3/statements/ModificationStatement.java | 2 +-
.../cassandra/cql3/statements/SelectStatement.java | 76 +-
.../statements/schema/AlterTableStatement.java | 113 +-
.../statements/schema/CreateTableStatement.java | 158 +-
.../statements/schema/CreateViewStatement.java | 25 +-
.../statements/schema/DropFunctionStatement.java | 7 +
src/java/org/apache/cassandra/db/Columns.java | 6 +-
src/java/org/apache/cassandra/db/Directories.java | 13 +
src/java/org/apache/cassandra/db/Keyspace.java | 2 +-
.../cassandra/db/ReadCommandVerbHandler.java | 9 +-
.../org/apache/cassandra/db/SystemKeyspace.java | 11 +-
.../cassandra/db/aggregation/GroupMaker.java | 4 +-
.../apache/cassandra/db/commitlog/CommitLog.java | 47 +-
.../cassandra/db/compaction/CompactionManager.java | 23 +
.../compaction/DateTieredCompactionStrategy.java | 519 --
.../DateTieredCompactionStrategyOptions.java | 156 -
.../cassandra/db/partitions/PartitionUpdate.java | 9 +-
.../org/apache/cassandra/db/view/ViewManager.java | 16 +-
.../cassandra/db/virtual/SnapshotsTable.java | 82 +
.../cassandra/db/virtual/SystemViewsKeyspace.java | 1 +
.../cassandra/db/virtual/TableMetricTables.java | 4 +-
.../org/apache/cassandra/dht/RangeStreamer.java | 4 +-
.../exceptions/InvalidRoutingException.java | 51 +
.../cassandra/exceptions/RequestFailureReason.java | 4 +
.../org/apache/cassandra/gms/FailureDetector.java | 7 +-
src/java/org/apache/cassandra/gms/Gossiper.java | 31 +-
.../apache/cassandra/hadoop/ColumnFamilySplit.java | 126 -
.../org/apache/cassandra/hadoop/ConfigHelper.java | 408 -
.../org/apache/cassandra/hadoop/HadoopCompat.java | 350 -
.../apache/cassandra/hadoop/ReporterWrapper.java | 85 -
.../cassandra/hadoop/cql3/CqlBulkOutputFormat.java | 209 -
.../cassandra/hadoop/cql3/CqlBulkRecordWriter.java | 332 -
.../cassandra/hadoop/cql3/CqlClientHelper.java | 109 -
.../cassandra/hadoop/cql3/CqlConfigHelper.java | 654 --
.../cassandra/hadoop/cql3/CqlInputFormat.java | 502 --
.../cassandra/hadoop/cql3/CqlOutputFormat.java | 143 -
.../cassandra/hadoop/cql3/CqlRecordReader.java | 784 --
.../cassandra/hadoop/cql3/CqlRecordWriter.java | 536 --
.../LimitedLocalNodeFirstLocalBalancingPolicy.java | 216 -
.../cassandra/index/SecondaryIndexManager.java | 2 +-
.../io/sstable/format/SortedTableScrubber.java | 3 +-
src/java/org/apache/cassandra/io/util/File.java | 12 +-
.../org/apache/cassandra/locator/ReplicaPlans.java | 5 -
.../org/apache/cassandra/metrics/TableMetrics.java | 2 +-
.../org/apache/cassandra/net/MessagingService.java | 4 +-
.../org/apache/cassandra/net/RequestCallbacks.java | 69 +-
.../apache/cassandra/net/ResponseVerbHandler.java | 24 +-
.../apache/cassandra/schema/ColumnMetadata.java | 98 +-
.../apache/cassandra/schema/DistributedSchema.java | 18 +-
.../org/apache/cassandra/schema/DroppedColumn.java | 8 +-
.../apache/cassandra/schema/KeyspaceMetadata.java | 20 +-
.../apache/cassandra/schema/SchemaKeyspace.java | 156 +-
.../cassandra/schema/SchemaKeyspaceTables.java | 4 +-
.../org/apache/cassandra/schema/TableMetadata.java | 137 +-
src/java/org/apache/cassandra/schema/Tables.java | 8 +-
.../org/apache/cassandra/schema/ViewMetadata.java | 20 +-
src/java/org/apache/cassandra/schema/Views.java | 8 +-
.../security/FileBasedSslContextFactory.java | 5 +-
.../apache/cassandra/security/JKSKeyProvider.java | 4 +-
.../security/PEMBasedSslContextFactory.java | 3 +-
.../service/AbstractWriteResponseHandler.java | 2 +-
.../apache/cassandra/service/CassandraDaemon.java | 21 +-
.../org/apache/cassandra/service/ClientState.java | 21 +
.../service/FileSystemOwnershipCheck.java | 3 +-
.../apache/cassandra/service/StartupChecks.java | 7 +-
.../org/apache/cassandra/service/StorageProxy.java | 13 +-
.../apache/cassandra/service/StorageService.java | 94 +-
.../org/apache/cassandra/service/paxos/Paxos.java | 2 +-
.../cassandra/service/snapshot/SnapshotLoader.java | 7 +-
.../cassandra/service/snapshot/TableSnapshot.java | 3 +-
.../apache/cassandra/streaming/SessionInfo.java | 13 +-
.../apache/cassandra/streaming/StreamManager.java | 24 +-
.../cassandra/streaming/StreamResultFuture.java | 12 +-
.../apache/cassandra/streaming/StreamSession.java | 80 +-
.../apache/cassandra/streaming/StreamState.java | 4 +
.../apache/cassandra/streaming/StreamingState.java | 20 +-
.../management/SessionInfoCompositeData.java | 2 +-
.../cassandra/tcm/AbstractLocalProcessor.java | 40 +-
.../cassandra/tcm/AtomicLongBackedProcessor.java | 2 +-
.../org/apache/cassandra/tcm/ClusterMetadata.java | 6 +
.../cassandra/tcm/ClusterMetadataService.java | 80 +-
src/java/org/apache/cassandra/tcm/Commit.java | 18 +-
src/java/org/apache/cassandra/tcm/Discovery.java | 2 +-
.../apache/cassandra/tcm/PaxosBackedProcessor.java | 17 +-
.../GossipProcessor.java => Processor.java} | 32 +-
.../org/apache/cassandra/tcm/RemoteProcessor.java | 68 +-
src/java/org/apache/cassandra/tcm/Startup.java | 39 +-
.../org/apache/cassandra/tcm/Transformation.java | 12 +-
.../cassandra/tcm/compatibility/GossipHelper.java | 15 +-
.../tcm/listeners/LegacyStateListener.java | 15 +-
.../cassandra/tcm/listeners/SchemaListener.java | 2 +
.../org/apache/cassandra/tcm/log/LocalLog.java | 2 +-
.../cassandra/tcm/migration/GossipProcessor.java | 4 +-
.../tcm/ownership/UniformRangePlacement.java | 2 +
.../apache/cassandra/tcm/sequences/AddToCMS.java | 64 +-
.../cassandra/tcm/sequences/BootstrapAndJoin.java | 6 +-
.../org/apache/cassandra/tcm/sequences/Move.java | 1 -
.../UDTAndFunctionsAwareMetadataSerializer.java | 63 +
.../cassandra/tcm/transformations/PrepareJoin.java | 52 +-
.../tcm/transformations/PrepareLeave.java | 1 -
.../cassandra/tcm/transformations/PrepareMove.java | 1 -
.../cassandra/tcm/transformations/UnsafeJoin.java | 1 +
.../cms/BaseMembershipTransformation.java | 6 +
.../{FinishAddMember.java => FinishAddToCMS.java} | 18 +-
.../cms/{RemoveMember.java => RemoveFromCMS.java} | 10 +-
.../{StartAddMember.java => StartAddToCMS.java} | 20 +-
.../org/apache/cassandra/tools/HashPassword.java | 5 +-
.../cassandra/tools/SSTableMetadataViewer.java | 1 +
.../cassandra/tools/SSTableRepairedAtSetter.java | 3 +-
.../apache/cassandra/tools/StandaloneUpgrader.java | 4 +-
.../tools/nodetool/stats/TableStatsHolder.java | 2 +-
src/java/org/apache/cassandra/utils/HeapUtils.java | 3 +-
.../cassandra/utils/NativeSSTableLoaderClient.java | 4 +-
.../org/apache/cassandra/utils/ObjectSizes.java | 21 +
src/java/org/apache/cassandra/utils/TimeUUID.java | 1 +
.../org/apache/cassandra/utils/binlog/BinLog.java | 12 +-
.../cassandra/transport/SimpleClientPerfTest.java | 2 +-
.../cassandra/distributed/impl/Instance.java | 2 +-
.../cassandra/distributed/impl/InstanceConfig.java | 4 +-
.../cassandra/distributed/test/ColumnMaskTest.java | 200 +
.../distributed/test/HintsDisabledTest.java | 74 +
.../distributed/test/IPMembershipTest.java | 5 +
.../cassandra/distributed/test/JVMDTestTest.java | 8 +-
.../distributed/test/MigrationCoordinatorTest.java | 128 -
.../cassandra/distributed/test/ReadRepairTest.java | 45 +-
.../distributed/test/SSTableIdGenerationTest.java | 26 +-
.../cassandra/distributed/test/SnapshotsTest.java | 3 +-
.../test/log/BounceIndexRebuildTest.java | 52 +
.../distributed/test/log/CMSTestBase.java | 11 +-
.../distributed/test/log/CoordinatorPathTest.java | 6 +-
.../test/log/CoordinatorPathTestBase.java | 84 +-
.../distributed/test/log/DistributedLogTest.java | 4 +-
.../distributed/test/log/FailedLeaveTest.java | 2 +-
.../test/log/MetadataChangeSimulationTest.java | 162 +-
.../distributed/test/log/PlacementSimulator.java | 401 +-
.../test/log/PlacementSimulatorTest.java | 55 +-
.../distributed/test/log/TestProcessor.java | 8 +-
.../distributed/test/ring/CMSMembershipTest.java | 136 +
.../test/ring/ConsistentBootstrapTest.java | 27 -
.../test/streaming/AbstractStreamFailureLogs.java | 175 +
.../test/streaming/BoundExceptionTest.java | 165 +
...amFailureLogsFailureDueToSessionFailedTest.java | 19 +-
...mFailureLogsFailureDueToSessionTimeoutTest.java | 181 +
...amFailureLogsFailureInTheMiddleWithEOFTest.java | 19 +-
...ilureLogsFailureInTheMiddleWithUnknownTest.java | 19 +-
.../util/SingleHostLoadBalancingPolicy.java | 100 +
.../microbench/ZeroCopyStreamingBenchmark.java | 2 +-
.../btree/AtomicBTreePartitionUpdateBench.java | 8 +-
.../cassandra/simulator/SimulationException.java | 24 +-
.../cassandra/simulator/SimulationRunner.java | 7 +-
.../simulator/debug/SelfReconcilingRandom.java | 20 +-
test/unit/org/apache/cassandra/SchemaLoader.java | 6 +-
.../unit/org/apache/cassandra/ServerTestUtils.java | 3 +-
.../cassandra/auth/CreateAndAlterRoleTest.java | 46 +-
test/unit/org/apache/cassandra/cql3/CQLTester.java | 28 +
test/unit/org/apache/cassandra/cql3/ViewTest.java | 4 +-
.../cassandra/cql3/functions/TimeFctsTest.java | 19 -
.../masking/ColumnMaskInAnyPositionTester.java | 267 +
.../ColumnMaskInAnyPositionWithDefaultTest.java | 45 +
.../ColumnMaskInAnyPositionWithNullTest.java | 25 +-
.../ColumnMaskInAnyPositionWithPartialTest.java | 54 +
.../ColumnMaskInAnyPositionWithReplaceTest.java | 53 +
.../ColumnMaskInAnyPositionWithUDFTest.java | 71 +
.../masking/ColumnMaskNativeTypesTest.java | 89 +
.../functions/masking/ColumnMaskQueryTester.java | 128 +
.../masking/ColumnMaskQueryWithDefaultTest.java | 46 +
.../masking/ColumnMaskQueryWithNullTest.java | 37 +-
.../masking/ColumnMaskQueryWithPartialTest.java | 48 +
.../masking/ColumnMaskQueryWithReplaceTest.java | 49 +
.../masking/ColumnMaskQueryWithUDFTest.java | 71 +
.../cql3/functions/masking/ColumnMaskTest.java | 580 ++
.../cql3/functions/masking/ColumnMaskTester.java | 158 +
.../ColumnMaskWithTypeAlteringFunctionTest.java | 148 +
.../functions/masking/ColumnMaskWithUDFTest.java | 284 +
.../functions/masking/MaskingFunctionTester.java | 8 +-
.../masking/SelectMaskedPermissionTest.java | 367 +
.../functions/masking/UnmaskPermissionTest.java | 223 +
.../cql3/statements/DescribeStatementTest.java | 57 +-
.../cql3/validation/entities/TimeuuidTest.java | 5 +-
.../cql3/validation/entities/TypeTest.java | 4 -
.../cql3/validation/entities/VirtualTableTest.java | 24 +-
.../validation/miscellaneous/OverflowTest.java | 2 +-
.../cql3/validation/operations/SelectTest.java | 2 +-
test/unit/org/apache/cassandra/db/CellTest.java | 3 +-
test/unit/org/apache/cassandra/db/ColumnsTest.java | 2 +-
.../org/apache/cassandra/db/NativeCellTest.java | 3 +-
.../compaction/AbstractCompactionStrategyTest.java | 16 -
.../db/compaction/CompactionIteratorTest.java | 4 +-
.../db/compaction/CompactionsCQLTest.java | 32 +-
.../DateTieredCompactionStrategyTest.java | 389 -
.../cassandra/db/compaction/NeverPurgeTest.java | 2 +-
.../cassandra/db/guardrails/GuardrailTester.java | 8 +
.../CassandraEntireSSTableStreamWriterTest.java | 2 +-
...TableStreamConcurrentComponentMutationTest.java | 2 +-
.../db/transform/DuplicateRowCheckerTest.java | 10 +-
.../cassandra/db/virtual/SnapshotsTableTest.java | 105 +
.../db/virtual/StreamingVirtualTableTest.java | 8 +-
.../cassandra/io/sstable/SSTableHeaderFixTest.java | 2 +-
.../io/sstable/keycache/KeyCacheTest.java | 2 -
.../apache/cassandra/metrics/TableMetricsTest.java | 44 +
.../cassandra/net/WriteCallbackInfoTest.java | 116 -
.../cassandra/schema/SchemaKeyspaceTest.java | 2 +-
...ntireSSTableStreamingCorrectFilesCountTest.java | 3 +-
.../cassandra/streaming/SessionInfoTest.java | 2 +-
.../org/apache/cassandra/tcm/DebounceTest.java | 73 +
.../org/apache/cassandra/tcm/log/LocalLogTest.java | 4 +-
.../UniformRangePlacementIntegrationTest.java | 103 +
.../InProgressSequenceCancellationTest.java | 5 +-
.../cassandra/tools/nodetool/NetStatsTest.java | 3 +-
.../cassandra/utils/CassandraGenerators.java | 2 +-
301 files changed, 19413 insertions(+), 23250 deletions(-)
copy .circleci/{config.yml => config_11_and_17.yml} (81%)
copy .circleci/{config.yml => config_11_and_17.yml.FREE} (81%)
copy .circleci/{config.yml.PAID => config_11_and_17.yml.PAID} (81%)
copy .circleci/{config_template.yml => config_template_11_and_17.yml} (77%)
copy .circleci/{config_template.yml.PAID.patch =>
config_template_11_and_17.yml.PAID.patch} (67%)
create mode 100755 .circleci/generate_11_and_17.sh
create mode 100644 doc/modules/cassandra/examples/CQL/ddm_alter_mask.cql
create mode 100644 doc/modules/cassandra/examples/CQL/ddm_create_table.cql
create mode 100644
doc/modules/cassandra/examples/CQL/ddm_create_table_with_udf.cql
create mode 100644 doc/modules/cassandra/examples/CQL/ddm_create_users.cql
create mode 100644 doc/modules/cassandra/examples/CQL/ddm_drop_mask.cql
create mode 100644 doc/modules/cassandra/examples/CQL/ddm_insert_data.cql
create mode 100644 doc/modules/cassandra/examples/CQL/ddm_revoke_unmask.cql
create mode 100644
doc/modules/cassandra/examples/CQL/ddm_select_with_masked_columns.cql
create mode 100644
doc/modules/cassandra/examples/CQL/ddm_select_with_select_masked.cql
create mode 100644
doc/modules/cassandra/examples/CQL/ddm_select_with_unmask_permission.cql
create mode 100644
doc/modules/cassandra/examples/CQL/ddm_select_without_select_masked.cql
create mode 100644
doc/modules/cassandra/examples/CQL/ddm_select_without_unmask_permission.cql
create mode 100644
doc/modules/cassandra/examples/CQL/select_with_mask_functions.cql
create mode 100644 doc/modules/cassandra/pages/cql/dynamic_data_masking.adoc
create mode 100644 doc/modules/cassandra/partials/masking_functions.adoc
create mode 100644
src/java/org/apache/cassandra/cql3/functions/masking/ColumnMask.java
delete mode 100644
src/java/org/apache/cassandra/db/compaction/DateTieredCompactionStrategy.java
delete mode 100644
src/java/org/apache/cassandra/db/compaction/DateTieredCompactionStrategyOptions.java
create mode 100644 src/java/org/apache/cassandra/db/virtual/SnapshotsTable.java
create mode 100644
src/java/org/apache/cassandra/exceptions/InvalidRoutingException.java
delete mode 100644 src/java/org/apache/cassandra/hadoop/ColumnFamilySplit.java
delete mode 100644 src/java/org/apache/cassandra/hadoop/ConfigHelper.java
delete mode 100644 src/java/org/apache/cassandra/hadoop/HadoopCompat.java
delete mode 100644 src/java/org/apache/cassandra/hadoop/ReporterWrapper.java
delete mode 100644
src/java/org/apache/cassandra/hadoop/cql3/CqlBulkOutputFormat.java
delete mode 100644
src/java/org/apache/cassandra/hadoop/cql3/CqlBulkRecordWriter.java
delete mode 100644
src/java/org/apache/cassandra/hadoop/cql3/CqlClientHelper.java
delete mode 100644
src/java/org/apache/cassandra/hadoop/cql3/CqlConfigHelper.java
delete mode 100644
src/java/org/apache/cassandra/hadoop/cql3/CqlInputFormat.java
delete mode 100644
src/java/org/apache/cassandra/hadoop/cql3/CqlOutputFormat.java
delete mode 100644
src/java/org/apache/cassandra/hadoop/cql3/CqlRecordReader.java
delete mode 100644
src/java/org/apache/cassandra/hadoop/cql3/CqlRecordWriter.java
delete mode 100644
src/java/org/apache/cassandra/hadoop/cql3/LimitedLocalNodeFirstLocalBalancingPolicy.java
copy src/java/org/apache/cassandra/tcm/{migration/GossipProcessor.java =>
Processor.java} (53%)
create mode 100644
src/java/org/apache/cassandra/tcm/serialization/UDTAndFunctionsAwareMetadataSerializer.java
rename
src/java/org/apache/cassandra/tcm/transformations/cms/{FinishAddMember.java =>
FinishAddToCMS.java} (86%)
rename
src/java/org/apache/cassandra/tcm/transformations/cms/{RemoveMember.java =>
RemoveFromCMS.java} (86%)
rename
src/java/org/apache/cassandra/tcm/transformations/cms/{StartAddMember.java =>
StartAddToCMS.java} (86%)
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/ColumnMaskTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/HintsDisabledTest.java
delete mode 100644
test/distributed/org/apache/cassandra/distributed/test/MigrationCoordinatorTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/log/BounceIndexRebuildTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/ring/CMSMembershipTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/streaming/AbstractStreamFailureLogs.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/streaming/BoundExceptionTest.java
copy src/java/org/apache/cassandra/hadoop/package-info.java =>
test/distributed/org/apache/cassandra/distributed/test/streaming/StreamFailureLogsFailureDueToSessionFailedTest.java
(68%)
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/streaming/StreamFailureLogsFailureDueToSessionTimeoutTest.java
copy src/java/org/apache/cassandra/hadoop/package-info.java =>
test/distributed/org/apache/cassandra/distributed/test/streaming/StreamFailureLogsFailureInTheMiddleWithEOFTest.java
(63%)
copy src/java/org/apache/cassandra/hadoop/package-info.java =>
test/distributed/org/apache/cassandra/distributed/test/streaming/StreamFailureLogsFailureInTheMiddleWithUnknownTest.java
(68%)
create mode 100644
test/distributed/org/apache/cassandra/distributed/util/SingleHostLoadBalancingPolicy.java
copy src/java/org/apache/cassandra/hadoop/package-info.java =>
test/simulator/main/org/apache/cassandra/simulator/SimulationException.java
(59%)
create mode 100644
test/unit/org/apache/cassandra/cql3/functions/masking/ColumnMaskInAnyPositionTester.java
create mode 100644
test/unit/org/apache/cassandra/cql3/functions/masking/ColumnMaskInAnyPositionWithDefaultTest.java
rename src/java/org/apache/cassandra/hadoop/package-info.java =>
test/unit/org/apache/cassandra/cql3/functions/masking/ColumnMaskInAnyPositionWithNullTest.java
(52%)
create mode 100644
test/unit/org/apache/cassandra/cql3/functions/masking/ColumnMaskInAnyPositionWithPartialTest.java
create mode 100644
test/unit/org/apache/cassandra/cql3/functions/masking/ColumnMaskInAnyPositionWithReplaceTest.java
create mode 100644
test/unit/org/apache/cassandra/cql3/functions/masking/ColumnMaskInAnyPositionWithUDFTest.java
create mode 100644
test/unit/org/apache/cassandra/cql3/functions/masking/ColumnMaskNativeTypesTest.java
create mode 100644
test/unit/org/apache/cassandra/cql3/functions/masking/ColumnMaskQueryTester.java
create mode 100644
test/unit/org/apache/cassandra/cql3/functions/masking/ColumnMaskQueryWithDefaultTest.java
copy src/java/org/apache/cassandra/tcm/migration/GossipProcessor.java =>
test/unit/org/apache/cassandra/cql3/functions/masking/ColumnMaskQueryWithNullTest.java
(51%)
create mode 100644
test/unit/org/apache/cassandra/cql3/functions/masking/ColumnMaskQueryWithPartialTest.java
create mode 100644
test/unit/org/apache/cassandra/cql3/functions/masking/ColumnMaskQueryWithReplaceTest.java
create mode 100644
test/unit/org/apache/cassandra/cql3/functions/masking/ColumnMaskQueryWithUDFTest.java
create mode 100644
test/unit/org/apache/cassandra/cql3/functions/masking/ColumnMaskTest.java
create mode 100644
test/unit/org/apache/cassandra/cql3/functions/masking/ColumnMaskTester.java
create mode 100644
test/unit/org/apache/cassandra/cql3/functions/masking/ColumnMaskWithTypeAlteringFunctionTest.java
create mode 100644
test/unit/org/apache/cassandra/cql3/functions/masking/ColumnMaskWithUDFTest.java
create mode 100644
test/unit/org/apache/cassandra/cql3/functions/masking/SelectMaskedPermissionTest.java
create mode 100644
test/unit/org/apache/cassandra/cql3/functions/masking/UnmaskPermissionTest.java
delete mode 100644
test/unit/org/apache/cassandra/db/compaction/DateTieredCompactionStrategyTest.java
create mode 100644
test/unit/org/apache/cassandra/db/virtual/SnapshotsTableTest.java
delete mode 100644
test/unit/org/apache/cassandra/net/WriteCallbackInfoTest.java
create mode 100644 test/unit/org/apache/cassandra/tcm/DebounceTest.java
create mode 100644
test/unit/org/apache/cassandra/tcm/ownership/UniformRangePlacementIntegrationTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
