Path	Lines of Code
cassandra-analytics-common/src/main/java/org/apache/cassandra/analytics/stats/Stats.java	175
cassandra-analytics-common/src/main/java/org/apache/cassandra/bridge/BigNumberConfig.java	27
cassandra-analytics-common/src/main/java/org/apache/cassandra/bridge/BigNumberConfigImpl.java	140
cassandra-analytics-common/src/main/java/org/apache/cassandra/bridge/CassandraVersion.java	53
cassandra-analytics-common/src/main/java/org/apache/cassandra/bridge/CassandraVersionFeatures.java	145
cassandra-analytics-common/src/main/java/org/apache/cassandra/bridge/SSTableDescriptor.java	29
cassandra-analytics-common/src/main/java/org/apache/cassandra/bridge/SSTableSummary.java	14
cassandra-analytics-common/src/main/java/org/apache/cassandra/bridge/SSTableWriter.java	11
cassandra-analytics-common/src/main/java/org/apache/cassandra/bridge/TokenRange.java	115
cassandra-analytics-common/src/main/java/org/apache/cassandra/bridge/type/InternalDuration.java	50
cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/api/CassandraSource.java	12
cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/api/CdcOptions.java	104
cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/api/CommitLog.java	77
cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/api/CommitLogInstance.java	9
cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/api/CommitLogMarkers.java	79
cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/api/CommitLogReader.java	42
cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/api/KeyspaceTypeKey.java	43
cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/api/Marker.java	109
cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/api/Mutation.java	4
cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/api/PerInstanceCommitLogMarkers.java	111
cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/api/PerRangeCommitLogMarkers.java	130
cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/api/RangeTombstoneData.java	21
cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/api/Row.java	23
cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/api/TableIdLookup.java	10
cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/msg/CdcEvent.java	134
cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/msg/CdcEventBuilder.java	149
cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/msg/RangeTombstone.java	38
cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/msg/RangeTombstoneBuilder.java	28
cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/msg/Value.java	39
cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/scanner/CdcStreamScanner.java	8
cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/state/CdcState.java	319
cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/stats/ICdcStats.java	108
cassandra-analytics-common/src/main/java/org/apache/cassandra/db/commitlog/PartitionUpdateWrapper.java	237
cassandra-analytics-common/src/main/java/org/apache/cassandra/secrets/SecretsProvider.java	27
cassandra-analytics-common/src/main/java/org/apache/cassandra/secrets/SslConfig.java	308
cassandra-analytics-common/src/main/java/org/apache/cassandra/secrets/SslConfigSecretsProvider.java	151
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/common/SSTables.java	21
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/common/model/BulkFeatures.java	11
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/common/model/CassandraInstance.java	13
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/common/model/NodeState.java	19
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/common/model/NodeStatus.java	19
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/common/stats/JobStatsPublisher.java	6
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/common/stats/LogStatsPublisher.java	13
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/BasicSupplier.java	22
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/BridgeUdtValue.java	38
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/CassandraTypes.java	168
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/CqlField.java	361
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/CqlTable.java	268
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/DefaultSizing.java	14
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/FileSystemSSTable.java	85
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/FileSystemSource.java	117
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/FileType.java	53
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/IncompleteSSTableException.java	17
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/QualifiedTableName.java	46
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/ReplicationFactor.java	167
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/SSTable.java	64
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/SSTablesSupplier.java	12
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/Sizing.java	5
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/TypeConverter.java	7
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/model/TokenOwner.java	5
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/partitioner/CassandraInstance.java	84
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/partitioner/CassandraRing.java	249
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/partitioner/ConsistencyLevel.java	95
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/partitioner/MurmurHash.java	100
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/partitioner/NotEnoughReplicasException.java	34
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/partitioner/Partitioner.java	67
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/partitioner/TokenPartitioner.java	230
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/exception/AnalyticsException.java	21
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/exception/ConsistencyNotSatisfiedException.java	13
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/exception/ImportFailedException.java	30
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/exception/S3ApiCallException.java	9
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/exception/SidecarApiCallException.java	13
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/exception/TimeSkewTooLargeException.java	15
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/exception/UnsupportedAnalyticsOperationException.java	9
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/exceptions/TransportFailureException.java	64
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/reader/EmptyStreamScanner.java	28
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/reader/IndexConsumer.java	7
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/reader/IndexEntry.java	43
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/reader/RowData.java	72
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/reader/SparkSSTableReader.java	18
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/reader/StreamScanner.java	14
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/reader/common/AbstractCompressionMetadata.java	57
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/reader/common/BigLongArray.java	50
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/reader/common/ChunkCorruptException.java	9
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/reader/common/IIndexReader.java	5
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/reader/common/SSTableStreamException.java	31
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/sparksql/Cell.java	15
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/sparksql/CellIterator.java	280
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/sparksql/FullRowBuilder.java	104
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/sparksql/NoMatchFoundException.java	11
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/sparksql/PartialRowBuilder.java	98
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/sparksql/RowBuilder.java	18
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/sparksql/RowIterator.java	129
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/sparksql/filters/PartitionKeyFilter.java	114
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/sparksql/filters/PruneColumnFilter.java	31
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/sparksql/filters/SparkRangeFilter.java	36
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/stats/BufferingInputStreamStats.java	42
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/ArrayUtils.java	66
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/AsyncExecutor.java	86
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/BuildInfo.java	78
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/ByteBufferUtils.java	245
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/ComparisonUtils.java	170
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/CqlUtils.java	201
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/FutureUtils.java	154
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/IOUtils.java	74
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/KryoUtils.java	129
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/LoggerHelper.java	117
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/MapUtils.java	148
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/Pair.java	42
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/Preconditions.java	61
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/Properties.java	38
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/RandomUtils.java	113
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/RangeUtils.java	118
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/ReaderTimeProvider.java	18
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/TableIdentifier.java	51
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/ThrowableUtils.java	32
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/Throwing.java	62
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/TimeProvider.java	21
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/TimeUtils.java	12
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/UUIDs.java	56
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/streaming/BufferingInputStream.java	412
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/streaming/CassandraFile.java	4
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/streaming/CassandraFileSource.java	30
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/streaming/StreamBuffer.java	46
cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/streaming/StreamConsumer.java	7
cassandra-analytics-common/src/main/java/org/apache/cassandra/util/CompressionUtil.java	10
cassandra-analytics-common/src/main/java/org/apache/cassandra/util/StatsUtil.java	23
cassandra-analytics-common/src/main/java/org/apache/cassandra/util/ThreadUtil.java	27