Path Lines of Code pylib/cqlshlib/copyutil.py 1824 src/java/org/apache/cassandra/audit/AuditLogOptionsCompositeData.java 182 src/java/org/apache/cassandra/batchlog/BatchlogManager.java 535 src/java/org/apache/cassandra/concurrent/ExecutionFailure.java 157 src/java/org/apache/cassandra/concurrent/SEPExecutor.java 316 src/java/org/apache/cassandra/concurrent/ScheduledThreadPoolExecutorPlus.java 195 src/java/org/apache/cassandra/concurrent/SharedExecutorPool.java 101 src/java/org/apache/cassandra/config/AccordSpec.java 143 src/java/org/apache/cassandra/config/CassandraRelevantProperties.java 630 src/java/org/apache/cassandra/config/Config.java 817 src/java/org/apache/cassandra/config/YamlConfigurationLoader.java 376 src/java/org/apache/cassandra/cql3/ColumnIdentifier.java 173 src/java/org/apache/cassandra/cql3/Operation.java 390 src/java/org/apache/cassandra/cql3/Operations.java 122 src/java/org/apache/cassandra/cql3/QueryProcessor.java 912 src/java/org/apache/cassandra/cql3/Relation.java 130 src/java/org/apache/cassandra/cql3/functions/UDFExecutorService.java 33 src/java/org/apache/cassandra/cql3/restrictions/SimpleRestriction.java 322 src/java/org/apache/cassandra/cql3/selection/Selectable.java 1196 src/java/org/apache/cassandra/cql3/statements/ListPermissionsStatement.java 109 src/java/org/apache/cassandra/cql3/statements/ModificationStatement.java 990 src/java/org/apache/cassandra/cql3/statements/TransactionStatement.java 602 src/java/org/apache/cassandra/cql3/statements/UpdateStatement.java 370 src/java/org/apache/cassandra/cql3/statements/schema/AlterSchemaStatement.java 181 src/java/org/apache/cassandra/cql3/statements/schema/AlterTableStatement.java 715 src/java/org/apache/cassandra/cql3/statements/schema/CreateFunctionStatement.java 203 src/java/org/apache/cassandra/cql3/statements/schema/DropTypeStatement.java 106 src/java/org/apache/cassandra/cql3/terms/Constants.java 491 src/java/org/apache/cassandra/cql3/terms/Lists.java 408 src/java/org/apache/cassandra/cql3/terms/Vectors.java 107 src/java/org/apache/cassandra/cql3/transactions/ConditionStatement.java 110 src/java/org/apache/cassandra/cql3/transactions/ReferenceOperation.java 130 src/java/org/apache/cassandra/cql3/transactions/RowDataReference.java 335 src/java/org/apache/cassandra/db/ClusteringPrefix.java 510 src/java/org/apache/cassandra/db/ColumnFamilyStore.java 2500 src/java/org/apache/cassandra/db/DeletionInfo.java 22 src/java/org/apache/cassandra/db/NativeClustering.java 130 src/java/org/apache/cassandra/db/ReadCommand.java 1091 src/java/org/apache/cassandra/db/ReadCommandVerbHandler.java 196 src/java/org/apache/cassandra/db/ReadExecutionController.java 174 src/java/org/apache/cassandra/db/ReadResponse.java 293 src/java/org/apache/cassandra/db/SerializationHeader.java 485 src/java/org/apache/cassandra/db/SinglePartitionReadCommand.java 1072 src/java/org/apache/cassandra/db/Slices.java 587 src/java/org/apache/cassandra/db/SystemKeyspace.java 1759 src/java/org/apache/cassandra/db/WriteType.java 12 src/java/org/apache/cassandra/db/commitlog/CommitLog.java 468 src/java/org/apache/cassandra/db/commitlog/DirectIOSegment.java 145 src/java/org/apache/cassandra/db/compaction/CompactionIterator.java 959 src/java/org/apache/cassandra/db/compaction/CompactionManager.java 2105 src/java/org/apache/cassandra/db/compaction/CompactionStrategyManager.java 1091 src/java/org/apache/cassandra/db/compaction/LeveledManifest.java 502 src/java/org/apache/cassandra/db/compaction/UnifiedCompactionStrategy.java 700 src/java/org/apache/cassandra/db/filter/DataLimits.java 923 src/java/org/apache/cassandra/db/filter/RowFilter.java 782 src/java/org/apache/cassandra/db/filter/TombstoneOverwhelmingException.java 40 src/java/org/apache/cassandra/db/lifecycle/Tracker.java 473 src/java/org/apache/cassandra/db/marshal/AbstractCompositeType.java 290 src/java/org/apache/cassandra/db/marshal/VectorType.java 573 src/java/org/apache/cassandra/db/partitions/PartitionUpdate.java 734 src/java/org/apache/cassandra/db/repair/CassandraValidationIterator.java 224 src/java/org/apache/cassandra/db/rows/BTreeRow.java 737 src/java/org/apache/cassandra/db/rows/ComplexColumnData.java 284 src/java/org/apache/cassandra/db/rows/NativeCell.java 168 src/java/org/apache/cassandra/db/rows/RowIterators.java 55 src/java/org/apache/cassandra/db/rows/UnfilteredRowIterators.java 399 src/java/org/apache/cassandra/db/streaming/CassandraEntireSSTableStreamWriter.java 72 src/java/org/apache/cassandra/db/streaming/CassandraStreamReader.java 287 src/java/org/apache/cassandra/db/streaming/CassandraStreamReceiver.java 243 src/java/org/apache/cassandra/db/transform/BaseIterator.java 109 src/java/org/apache/cassandra/db/view/TableViews.java 398 src/java/org/apache/cassandra/db/view/View.java 156 src/java/org/apache/cassandra/db/view/ViewBuilder.java 192 src/java/org/apache/cassandra/db/view/ViewManager.java 147 src/java/org/apache/cassandra/db/view/ViewUpdateGenerator.java 373 src/java/org/apache/cassandra/db/view/ViewUtils.java 50 src/java/org/apache/cassandra/db/virtual/AccordDebugKeyspace.java 634 src/java/org/apache/cassandra/dht/Murmur3Partitioner.java 425 src/java/org/apache/cassandra/dht/OrderPreservingPartitioner.java 288 src/java/org/apache/cassandra/dht/RangeStreamer.java 575 src/java/org/apache/cassandra/dht/tokenallocator/NoReplicationTokenAllocator.java 188 src/java/org/apache/cassandra/gms/Gossiper.java 1655 src/java/org/apache/cassandra/hints/HintsDispatcher.java 428 src/java/org/apache/cassandra/index/SecondaryIndexManager.java 1215 src/java/org/apache/cassandra/index/accord/CheckpointIntervalArrayIndex.java 681 src/java/org/apache/cassandra/index/accord/RangeMemoryIndex.java 205 src/java/org/apache/cassandra/index/accord/RouteJournalIndex.java 519 src/java/org/apache/cassandra/index/accord/RouteMemtableIndexManager.java 82 src/java/org/apache/cassandra/index/accord/RouteSSTableManager.java 74 src/java/org/apache/cassandra/index/accord/RouteSecondaryIndexBuilder.java 180 src/java/org/apache/cassandra/index/internal/composites/CompositesSearcher.java 240 src/java/org/apache/cassandra/index/sai/StorageAttachedIndexBuilder.java 250 src/java/org/apache/cassandra/index/sai/disk/ResettableByteBuffersIndexOutput.java 107 src/java/org/apache/cassandra/index/sai/disk/v1/bbtree/BlockBalancedTreeWriter.java 526 src/java/org/apache/cassandra/index/sai/disk/v1/postings/PostingsReader.java 251 src/java/org/apache/cassandra/index/sai/disk/v1/segment/VectorIndexSegmentSearcher.java 272 src/java/org/apache/cassandra/index/sai/memory/TrieMemoryIndex.java 282 src/java/org/apache/cassandra/index/sai/memory/VectorMemoryIndex.java 285 src/java/org/apache/cassandra/index/sai/plan/QueryController.java 340 src/java/org/apache/cassandra/index/sai/plan/StorageAttachedIndexSearcher.java 450 src/java/org/apache/cassandra/index/sasi/utils/trie/PatriciaTrie.java 771 src/java/org/apache/cassandra/io/compress/CompressionMetadata.java 423 src/java/org/apache/cassandra/io/sstable/SSTableRewriter.java 237 src/java/org/apache/cassandra/io/sstable/format/SSTableReader.java 1336 src/java/org/apache/cassandra/io/sstable/format/SortedTableScrubber.java 565 src/java/org/apache/cassandra/io/sstable/format/SortedTableVerifier.java 417 src/java/org/apache/cassandra/io/sstable/format/SortedTableWriter.java 405 src/java/org/apache/cassandra/io/sstable/format/big/BigTableReader.java 535 src/java/org/apache/cassandra/io/sstable/format/big/SSTableReversedIterator.java 313 src/java/org/apache/cassandra/io/sstable/metadata/MetadataCollector.java 379 src/java/org/apache/cassandra/io/sstable/metadata/StatsMetadata.java 574 src/java/org/apache/cassandra/io/util/ChannelProxy.java 144 src/java/org/apache/cassandra/io/util/File.java 449 src/java/org/apache/cassandra/io/util/FileUtils.java 628 src/java/org/apache/cassandra/io/util/PathUtils.java 659 src/java/org/apache/cassandra/io/util/SequentialWriter.java 324 src/java/org/apache/cassandra/journal/ActiveSegment.java 396 src/java/org/apache/cassandra/journal/Flusher.java 443 src/java/org/apache/cassandra/journal/InMemoryIndex.java 117 src/java/org/apache/cassandra/journal/Journal.java 814 src/java/org/apache/cassandra/journal/OnDiskIndex.java 272 src/java/org/apache/cassandra/journal/RecordPointer.java 50 src/java/org/apache/cassandra/journal/Segments.java 167 src/java/org/apache/cassandra/locator/AbstractReplicaCollection.java 490 src/java/org/apache/cassandra/locator/AbstractReplicationStrategy.java 275 src/java/org/apache/cassandra/locator/DynamicEndpointSnitch.java 326 src/java/org/apache/cassandra/locator/EndpointsByRange.java 38 src/java/org/apache/cassandra/locator/EndpointsByReplica.java 95 src/java/org/apache/cassandra/locator/RangesByEndpoint.java 100 src/java/org/apache/cassandra/locator/ReplicaLayout.java 252 src/java/org/apache/cassandra/locator/ReplicaPlan.java 333 src/java/org/apache/cassandra/locator/ReplicaPlans.java 749 src/java/org/apache/cassandra/metrics/AccordMetrics.java 213 src/java/org/apache/cassandra/metrics/InternodeOutboundMetrics.java 129 src/java/org/apache/cassandra/metrics/TCMMetrics.java 129 src/java/org/apache/cassandra/net/AbstractMessageHandler.java 504 src/java/org/apache/cassandra/net/AsyncStreamingInputPlus.java 141 src/java/org/apache/cassandra/net/FrameDecoderLZ4.java 99 src/java/org/apache/cassandra/net/InboundSink.java 151 src/java/org/apache/cassandra/net/LatencySubscribers.java 38 src/java/org/apache/cassandra/net/MessageDelivery.java 214 src/java/org/apache/cassandra/net/OutboundConnection.java 1130 src/java/org/apache/cassandra/net/RequestCallback.java 24 src/java/org/apache/cassandra/net/ResponseVerbHandler.java 93 src/java/org/apache/cassandra/repair/RepairMessageVerbHandler.java 395 src/java/org/apache/cassandra/repair/RepairSession.java 355 src/java/org/apache/cassandra/repair/SharedContext.java 261 src/java/org/apache/cassandra/schema/DistributedMetadataLogKeyspace.java 196 src/java/org/apache/cassandra/schema/DistributedSchema.java 356 src/java/org/apache/cassandra/schema/Schema.java 275 src/java/org/apache/cassandra/schema/SchemaDiagnostics.java 134 src/java/org/apache/cassandra/schema/SchemaEvent.java 275 src/java/org/apache/cassandra/schema/SchemaKeyspace.java 1145 src/java/org/apache/cassandra/schema/SchemaProvider.java 168 src/java/org/apache/cassandra/schema/SystemDistributedKeyspace.java 337 src/java/org/apache/cassandra/schema/TableId.java 326 src/java/org/apache/cassandra/schema/TableMetadata.java 1596 src/java/org/apache/cassandra/security/ThreadAwareSecurityManager.java 159 src/java/org/apache/cassandra/serializers/DurationSerializer.java 89 src/java/org/apache/cassandra/service/AbstractWriteResponseHandler.java 296 src/java/org/apache/cassandra/service/CassandraDaemon.java 686 src/java/org/apache/cassandra/service/StartupChecks.java 633 src/java/org/apache/cassandra/service/StorageProxy.java 2915 src/java/org/apache/cassandra/service/StorageService.java 4467 src/java/org/apache/cassandra/service/TimeoutStrategy.java 303 src/java/org/apache/cassandra/service/TruncateResponseHandler.java 80 src/java/org/apache/cassandra/service/accord/AbstractAccordSegmentCompactor.java 177 src/java/org/apache/cassandra/service/accord/AccordCache.java 1073 src/java/org/apache/cassandra/service/accord/AccordCacheEntry.java 539 src/java/org/apache/cassandra/service/accord/AccordCommandStore.java 482 src/java/org/apache/cassandra/service/accord/AccordCommandStores.java 226 src/java/org/apache/cassandra/service/accord/AccordConfigurationService.java 501 src/java/org/apache/cassandra/service/accord/AccordDataStore.java 142 src/java/org/apache/cassandra/service/accord/AccordExecutor.java 910 src/java/org/apache/cassandra/service/accord/AccordFastPathCoordinator.java 265 src/java/org/apache/cassandra/service/accord/AccordFetchCoordinator.java 353 src/java/org/apache/cassandra/service/accord/AccordJournal.java 739 src/java/org/apache/cassandra/service/accord/AccordJournalTable.java 402 src/java/org/apache/cassandra/service/accord/AccordJournalValueSerializers.java 263 src/java/org/apache/cassandra/service/accord/AccordKeyspace.java 490 src/java/org/apache/cassandra/service/accord/AccordMessageSink.java 215 src/java/org/apache/cassandra/service/accord/AccordObjectSizes.java 378 src/java/org/apache/cassandra/service/accord/AccordSafeCommandStore.java 193 src/java/org/apache/cassandra/service/accord/AccordService.java 824 src/java/org/apache/cassandra/service/accord/AccordSyncPropagator.java 341 src/java/org/apache/cassandra/service/accord/AccordTask.java 951 src/java/org/apache/cassandra/service/accord/AccordVerbHandler.java 45 src/java/org/apache/cassandra/service/accord/ClientRequestBookkeeping.java 52 src/java/org/apache/cassandra/service/accord/CommandsForRanges.java 212 src/java/org/apache/cassandra/service/accord/JournalKey.java 240 src/java/org/apache/cassandra/service/accord/RequestBookkeeping.java 77 src/java/org/apache/cassandra/service/accord/WatermarkCollector.java 228 src/java/org/apache/cassandra/service/accord/api/AccordAgent.java 282 src/java/org/apache/cassandra/service/accord/api/AccordRoutableKey.java 103 src/java/org/apache/cassandra/service/accord/interop/AccordInteropApply.java 207 src/java/org/apache/cassandra/service/accord/interop/AccordInteropExecution.java 358 src/java/org/apache/cassandra/service/accord/interop/AccordInteropReadRepair.java 138 src/java/org/apache/cassandra/service/accord/interop/AccordInteropStableThenRead.java 148 src/java/org/apache/cassandra/service/accord/journal/AccordTopologyUpdate.java 380 src/java/org/apache/cassandra/service/accord/serializers/ReadDataSerializers.java 314 src/java/org/apache/cassandra/service/accord/serializers/ResultSerializers.java 29 src/java/org/apache/cassandra/service/accord/serializers/TxnRequestSerializer.java 68 src/java/org/apache/cassandra/service/accord/txn/AccordUpdateParameters.java 79 src/java/org/apache/cassandra/service/accord/txn/TxnCondition.java 573 src/java/org/apache/cassandra/service/accord/txn/TxnDataKeyValue.java 78 src/java/org/apache/cassandra/service/accord/txn/TxnDataRangeValue.java 136 src/java/org/apache/cassandra/service/accord/txn/TxnNamedRead.java 403 src/java/org/apache/cassandra/service/accord/txn/TxnQuery.java 230 src/java/org/apache/cassandra/service/accord/txn/TxnRangeReadResult.java 36 src/java/org/apache/cassandra/service/accord/txn/TxnRead.java 383 src/java/org/apache/cassandra/service/accord/txn/TxnReference.java 284 src/java/org/apache/cassandra/service/accord/txn/TxnUpdate.java 323 src/java/org/apache/cassandra/service/accord/txn/TxnWrite.java 400 src/java/org/apache/cassandra/service/consensus/TransactionalMode.java 106 src/java/org/apache/cassandra/service/consensus/migration/ConsensusKeyMigrationState.java 292 src/java/org/apache/cassandra/service/consensus/migration/ConsensusMigrationState.java 222 src/java/org/apache/cassandra/service/consensus/migration/ConsensusRequestRouter.java 648 src/java/org/apache/cassandra/service/consensus/migration/ConsensusTableMigration.java 308 src/java/org/apache/cassandra/service/consensus/migration/TableMigrationState.java 330 src/java/org/apache/cassandra/service/disk/usage/DiskUsageBroadcaster.java 121 src/java/org/apache/cassandra/service/paxos/ContentionStrategy.java 276 src/java/org/apache/cassandra/service/paxos/Paxos.java 933 src/java/org/apache/cassandra/service/paxos/PaxosPrepare.java 1039 src/java/org/apache/cassandra/service/paxos/PaxosRepair.java 518 src/java/org/apache/cassandra/service/paxos/PaxosState.java 704 src/java/org/apache/cassandra/service/paxos/cleanup/PaxosCleanupRequest.java 116 src/java/org/apache/cassandra/service/reads/AbstractReadExecutor.java 358 src/java/org/apache/cassandra/service/reads/DigestResolver.java 121 src/java/org/apache/cassandra/service/reads/ReadCallback.java 203 src/java/org/apache/cassandra/service/reads/range/AccordRangeResponse.java 42 src/java/org/apache/cassandra/service/reads/range/RangeCommandIterator.java 365 src/java/org/apache/cassandra/service/snapshot/TableSnapshot.java 556 src/java/org/apache/cassandra/streaming/StreamRequest.java 107 src/java/org/apache/cassandra/streaming/StreamSession.java 996 src/java/org/apache/cassandra/tcm/AbstractLocalProcessor.java 133 src/java/org/apache/cassandra/tcm/ClusterMetadata.java 968 src/java/org/apache/cassandra/tcm/Commit.java 364 src/java/org/apache/cassandra/tcm/RemoteProcessor.java 325 src/java/org/apache/cassandra/tcm/Retry.java 118 src/java/org/apache/cassandra/tcm/log/Entry.java 144 src/java/org/apache/cassandra/tcm/log/LocalLog.java 743 src/java/org/apache/cassandra/tcm/log/SystemKeyspaceStorage.java 125 src/java/org/apache/cassandra/tcm/membership/NodeState.java 23 src/java/org/apache/cassandra/tcm/ownership/DataPlacement.java 167 src/java/org/apache/cassandra/tcm/ownership/PlacementProvider.java 28 src/java/org/apache/cassandra/tcm/ownership/TokenMap.java 232 src/java/org/apache/cassandra/tcm/sequences/BootstrapAndJoin.java 457 src/java/org/apache/cassandra/tcm/sequences/LockedRanges.java 377 src/java/org/apache/cassandra/tcm/sequences/UnbootstrapStreams.java 149 src/java/org/apache/cassandra/tcm/transformations/PrepareLeave.java 253 src/java/org/apache/cassandra/tcm/transformations/PrepareReplace.java 294 src/java/org/apache/cassandra/tcm/transformations/Register.java 177 src/java/org/apache/cassandra/tcm/transformations/cms/BaseMembershipTransformation.java 64 src/java/org/apache/cassandra/tools/SSTableLevelResetter.java 87 src/java/org/apache/cassandra/tools/nodetool/Sjk.java 410 src/java/org/apache/cassandra/transport/Compressor.java 146 src/java/org/apache/cassandra/transport/Dispatcher.java 313 src/java/org/apache/cassandra/transport/Server.java 527 src/java/org/apache/cassandra/transport/messages/BatchMessage.java 217 src/java/org/apache/cassandra/utils/DynamicList.java 190 src/java/org/apache/cassandra/utils/MerkleTree.java 1171 src/java/org/apache/cassandra/utils/MonotonicClock.java 252 src/java/org/apache/cassandra/utils/Nemesis.java 13 src/java/org/apache/cassandra/utils/PojoToString.java 130 src/java/org/apache/cassandra/utils/Simulate.java 12 src/java/org/apache/cassandra/utils/SystemInfo.java 115 src/java/org/apache/cassandra/utils/btree/BTree.java 2888 src/java/org/apache/cassandra/utils/btree/BTreeSet.java 552 src/java/org/apache/cassandra/utils/btree/NodeCursor.java 115 src/java/org/apache/cassandra/utils/btree/TreeCursor.java 159 src/java/org/apache/cassandra/utils/concurrent/AbstractFuture.java 368 src/java/org/apache/cassandra/utils/concurrent/ListenerList.java 278 src/java/org/apache/cassandra/utils/concurrent/LockWithAsyncSignal.java 210 src/java/org/apache/cassandra/utils/concurrent/Ref.java 675 src/java/org/apache/cassandra/utils/concurrent/WaitQueue.java 263 src/java/org/apache/cassandra/utils/memory/BufferPool.java 1138 tools/stress/src/org/apache/cassandra/stress/StressAction.java 406 tools/stress/src/org/apache/cassandra/stress/generate/PartitionIterator.java 580 tools/stress/src/org/apache/cassandra/stress/generate/values/Dates.java 21 tools/stress/src/org/apache/cassandra/stress/operations/predefined/CqlCounterAdder.java 55 tools/stress/src/org/apache/cassandra/stress/operations/userdefined/SchemaStatement.java 86 tools/stress/src/org/apache/cassandra/stress/util/JmxCollector.java 100 tools/stress/src/org/apache/cassandra/stress/util/Uncertainty.java 65