Path	Lines of Code
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/CdcEventTransformer.java	6
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/CdcLogMode.java	132
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/CdcLogger.java	9
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/AvroBaseRecordTransformer.java	69
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/AvroByteRecordTransformer.java	48
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/AvroDataUtils.java	114
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/AvroGenericRecordTransformer.java	84
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/AvroSerializer.java	140
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/CdcEventAvroEncoder.java	111
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/CdcEventUtils.java	271
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/RecordReader.java	59
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/TypeConversion.java	323
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/TypeConversionRegistry.java	36
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/msg/CdcEnvelope.java	12
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/msg/FieldValue.java	43
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/json/AvroJsonTransformer.java	50
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/json/CdcGenericData.java	30
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/json/JsonSerializer.java	26
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/kafka/AvroGenericRecordSerializer.java	131
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/kafka/EventHasher.java	26
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/kafka/KafkaCdcSerializer.java	7
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/kafka/KafkaOptions.java	6
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/kafka/KafkaPublisher.java	222
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/kafka/KafkaStats.java	23
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/kafka/RecordProducer.java	61
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/kafka/TopicSupplier.java	114
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/schemastore/CachingSchemaStore.java	210
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/schemastore/LocalTableSchemaStore.java	123
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/schemastore/PublishSchemaResult.java	13
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/schemastore/SchemaStore.java	24
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/schemastore/SchemaStorePublisherFactory.java	17
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/schemastore/SchemaStoreStats.java	7
cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/schemastore/TableSchemaPublisher.java	12
cassandra-analytics-cdc-codec/src/main/resources/cdc_bytes.avsc	159
cassandra-analytics-cdc-codec/src/main/resources/cdc_generic_record.avsc	155
cassandra-analytics-cdc-codec/src/main/resources/table_schemas/example.avsc	38
cassandra-analytics-cdc-sidecar/src/main/java/org/apache/cassandra/cdc/CassandraClientSource.java	127
cassandra-analytics-cdc-sidecar/src/main/java/org/apache/cassandra/cdc/sidecar/ClusterConfigProvider.java	10
cassandra-analytics-cdc-sidecar/src/main/java/org/apache/cassandra/cdc/sidecar/ReplicationFactorSupplier.java	23
cassandra-analytics-cdc-sidecar/src/main/java/org/apache/cassandra/cdc/sidecar/SidecarCdc.java	35
cassandra-analytics-cdc-sidecar/src/main/java/org/apache/cassandra/cdc/sidecar/SidecarCdcBuilder.java	135
cassandra-analytics-cdc-sidecar/src/main/java/org/apache/cassandra/cdc/sidecar/SidecarCdcCassandraClient.java	30
cassandra-analytics-cdc-sidecar/src/main/java/org/apache/cassandra/cdc/sidecar/SidecarCdcClient.java	118
cassandra-analytics-cdc-sidecar/src/main/java/org/apache/cassandra/cdc/sidecar/SidecarCdcCommitLogSegment.java	112
cassandra-analytics-cdc-sidecar/src/main/java/org/apache/cassandra/cdc/sidecar/SidecarCdcOptions.java	98
cassandra-analytics-cdc-sidecar/src/main/java/org/apache/cassandra/cdc/sidecar/SidecarCdcStats.java	97
cassandra-analytics-cdc-sidecar/src/main/java/org/apache/cassandra/cdc/sidecar/SidecarCommitLogProvider.java	101
cassandra-analytics-cdc-sidecar/src/main/java/org/apache/cassandra/cdc/sidecar/SidecarDownMonitor.java	23
cassandra-analytics-cdc-sidecar/src/main/java/org/apache/cassandra/cdc/sidecar/SidecarStatePersister.java	334
cassandra-analytics-cdc/src/main/java/org/apache/cassandra/bridge/CdcBridgeFactory.java	122
cassandra-analytics-cdc/src/main/java/org/apache/cassandra/cdc/Cdc.java	359
cassandra-analytics-cdc/src/main/java/org/apache/cassandra/cdc/CdcBuilder.java	116
cassandra-analytics-cdc/src/main/java/org/apache/cassandra/cdc/CdcKryoRegister.java	27
cassandra-analytics-cdc/src/main/java/org/apache/cassandra/cdc/MicroBatchIterator.java	151
cassandra-analytics-cdc/src/main/java/org/apache/cassandra/cdc/TypeCache.java	80
cassandra-analytics-cdc/src/main/java/org/apache/cassandra/cdc/api/CommitLogProvider.java	12
cassandra-analytics-cdc/src/main/java/org/apache/cassandra/cdc/api/EventConsumer.java	6
cassandra-analytics-cdc/src/main/java/org/apache/cassandra/cdc/api/MessageConverter.java	10
cassandra-analytics-cdc/src/main/java/org/apache/cassandra/cdc/api/SchemaSupplier.java	8
cassandra-analytics-cdc/src/main/java/org/apache/cassandra/cdc/api/StatePersister.java	32
cassandra-analytics-cdc/src/main/java/org/apache/cassandra/cdc/api/TokenRangeSupplier.java	6
cassandra-analytics-cdc/src/main/java/org/apache/cassandra/cdc/msg/jdk/CdcMessage.java	195
cassandra-analytics-cdc/src/main/java/org/apache/cassandra/cdc/msg/jdk/Column.java	43
cassandra-analytics-cdc/src/main/java/org/apache/cassandra/cdc/msg/jdk/JdkMessageConverter.java	32
cassandra-analytics-cdc/src/main/java/org/apache/cassandra/cdc/msg/jdk/RangeTombstoneMsg.java	39
cassandra-analytics-cdc/src/main/java/org/apache/cassandra/cdc/scanner/CdcScannerBuilder.java	311
cassandra-analytics-cdc/src/main/java/org/apache/cassandra/cdc/stats/CdcStats.java	27
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
cassandra-analytics-core-example/src/main/java/org/apache/cassandra/spark/example/AbstractCassandraJob.java	170
cassandra-analytics-core-example/src/main/java/org/apache/cassandra/spark/example/DirectWriteAndReadJob.java	40
cassandra-analytics-core-example/src/main/java/org/apache/cassandra/spark/example/ExampleStorageTransportExtension.java	143
cassandra-analytics-core-example/src/main/java/org/apache/cassandra/spark/example/JobSelector.java	34
cassandra-analytics-core-example/src/main/java/org/apache/cassandra/spark/example/LocalS3WriteAndReadJob.java	68
cassandra-analytics-core-example/src/main/java/org/apache/cassandra/spark/example/LocalStorageTransportExtension.java	110
cassandra-analytics-core/src/main/java/org/apache/cassandra/bridge/CassandraBridgeFactory.java	98
cassandra-analytics-core/src/main/java/org/apache/cassandra/clients/AnalyticsSidecarClient.java	60
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/KryoRegister.java	67
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/AbstractBulkWriterContext.java	212
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/BulkSparkConf.java	555
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/BulkWriteValidator.java	147
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/BulkWriterContext.java	14
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/BulkWriterContextFactory.java	67
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/CancelJobEvent.java	16
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/CassandraBulkSourceRelation.java	447
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/CassandraBulkWriterContext.java	32
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/CassandraClusterInfo.java	397
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/CassandraContext.java	100
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/CassandraDirectDataTransportContext.java	49
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/CassandraJobInfo.java	117
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/CassandraSchemaInfo.java	23
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/ClusterInfo.java	33
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/CommitCoordinator.java	176
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/CommitError.java	23
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/CommitResult.java	40
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/CqlTableInfoProvider.java	132
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/DataTransport.java	26
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/DataTransportInfo.java	33
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/DecoratedKey.java	62
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/DigestAlgorithmSupplier.java	7
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/DigestAlgorithms.java	23
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/DirectDataTransferApi.java	38
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/DirectStreamResult.java	33
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/DirectStreamSession.java	240
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/JobInfo.java	41
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/RecordWriter.java	375
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/RingInstance.java	165
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/SSTableWriterFactory.java	29
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/SchemaInfo.java	10
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/SidecarDataTransferApi.java	128
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/SimpleTaskScheduler.java	130
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/SortedSSTableWriter.java	233
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/SqlToCqlTypeConverter.java	762
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/StreamError.java	24
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/StreamResult.java	29
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/StreamSession.java	125
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/TTLOption.java	72
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/TableInfoProvider.java	17
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/TableSchema.java	258
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/TimestampOption.java	71
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/TokenPartitioner.java	197
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/Tokenizer.java	42
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/TransportContext.java	41
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/WriteAvailability.java	30
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/WriteMode.java	6
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/WriteResult.java	27
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/WriterOption.java	5
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/WriterOptions.java	47
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/Bundle.java	203
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/BundleManifest.java	67
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/BundleNameGenerator.java	20
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/BundleStorageObject.java	51
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/CassandraCloudStorageTransportContext.java	122
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/CassandraTopologyMonitor.java	79
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/CloudStorageDataTransferApi.java	29
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/CloudStorageDataTransferApiFactory.java	40
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/CloudStorageDataTransferApiImpl.java	217
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/CloudStorageStreamResult.java	48
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/CloudStorageStreamSession.java	297
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/CreatedRestoreSlice.java	131
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/DataChunker.java	57
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/ImportCompletionCoordinator.java	378
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/ImportCoordinator.java	10
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/SSTableCollector.java	32
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/SSTableLister.java	189
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/SSTablesBundler.java	152
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/StorageClient.java	203
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/StorageClientConfig.java	52
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/coordinated/CassandraClusterInfoGroup.java	246
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/coordinated/CassandraCoordinatedBulkWriterContext.java	54
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/coordinated/CoordinatedCloudStorageDataTransferApi.java	202
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/coordinated/CoordinatedCloudStorageDataTransferApiExtension.java	14
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/coordinated/CoordinatedImportCoordinator.java	197
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/coordinated/CoordinatedWriteConf.java	172
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/coordinated/MultiClusterContainer.java	121
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/coordinated/MultiClusterSupport.java	22
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/token/ConsistencyLevel.java	170
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/token/MultiClusterReplicaAwareFailureHandler.java	86
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/token/ReplicaAwareFailureHandler.java	74
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/token/SingleClusterReplicaAwareFailureHandler.java	139
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/token/TokenRangeMapping.java	204
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/token/TokenUtils.java	99
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/util/FastByteOperations.java	172
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/util/IOUtils.java	72
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/util/SbwJavaSerializer.java	73
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/util/SbwKryoRegistrator.java	52
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/util/TaskContextUtils.java	30
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/DataObjectBuilder.java	12
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/Digest.java	6
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/MD5Digest.java	28
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/SidecarInstanceFactory.java	34
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/XXHash32Digest.java	36
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/schema/BooleanType.java	22
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/schema/BytesType.java	26
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/schema/CollectionType.java	20
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/schema/ColumnType.java	8
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/schema/ColumnTypes.java	21
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/schema/ColumnUtil.java	30
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/schema/DoubleType.java	21
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/schema/IntegerType.java	17
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/schema/ListType.java	42
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/schema/LongType.java	17
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/schema/MapType.java	43
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/schema/SetType.java	21
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/schema/StringType.java	18
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/schema/StringUuidType.java	17
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/schema/TimestampType.java	18
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/schema/UuidType.java	26
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/CassandraDataLayer.java	893
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/CassandraDataSourceHelper.java	86
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/ClientConfig.java	383
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/DataLayer.java	202
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/LocalDataLayer.java	405
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/PartitionedDataLayer.java	384
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/SidecarProvisionedSSTable.java	194
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/partitioner/MultipleReplicas.java	106
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/partitioner/SingleReplica.java	138
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/sparksql/AbstractSparkRowIterator.java	62
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/sparksql/CassandraDataSink.java	72
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/sparksql/SparkCellIterator.java	68
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/transports/storage/StorageAccessConfiguration.java	82
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/transports/storage/StorageCredentialPair.java	57
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/transports/storage/StorageCredentials.java	102
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/transports/storage/extensions/CommonStorageTransportExtension.java	7
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/transports/storage/extensions/CoordinatedTransportExtension.java	10
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/transports/storage/extensions/CoordinationSignalListener.java	6
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/transports/storage/extensions/CredentialChangeListener.java	11
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/transports/storage/extensions/DriverStorageTransportExtension.java	11
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/transports/storage/extensions/ExecutorStorageTransportExtension.java	5
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/transports/storage/extensions/ObjectFailureListener.java	5
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/transports/storage/extensions/StorageTransportConfiguration.java	116
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/transports/storage/extensions/StorageTransportExtension.java	7
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/transports/storage/extensions/StorageTransportHandler.java	66
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/transports/storage/extensions/TransportExtensionUtils.java	19
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/utils/DigestAlgorithm.java	8
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/utils/FilterUtils.java	80
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/utils/MD5DigestAlgorithm.java	22
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/utils/ScalaFunctions.java	28
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/utils/XXHash32DigestAlgorithm.java	30
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/validation/BulkWriterKeyStoreValidation.java	15
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/validation/BulkWriterTrustStoreValidation.java	15
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/validation/CassandraValidation.java	31
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/validation/SidecarValidation.java	31
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/validation/SslValidation.java	22
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/validation/StartupValidatable.java	5
cassandra-analytics-core/src/main/spark2/org/apache/cassandra/spark/sparksql/CassandraDataSource.java	170
cassandra-analytics-core/src/main/spark2/org/apache/cassandra/spark/sparksql/LocalDataSource.java	21
cassandra-analytics-core/src/main/spark2/org/apache/cassandra/spark/sparksql/SparkRowIterator.java	56
cassandra-analytics-core/src/main/spark3/org/apache/cassandra/spark/sparksql/CassandraDataSource.java	30
cassandra-analytics-core/src/main/spark3/org/apache/cassandra/spark/sparksql/CassandraInputPartition.java	14
cassandra-analytics-core/src/main/spark3/org/apache/cassandra/spark/sparksql/CassandraPartitionReaderFactory.java	44
cassandra-analytics-core/src/main/spark3/org/apache/cassandra/spark/sparksql/CassandraPartitioning.java	35
cassandra-analytics-core/src/main/spark3/org/apache/cassandra/spark/sparksql/CassandraScanBuilder.java	113
cassandra-analytics-core/src/main/spark3/org/apache/cassandra/spark/sparksql/CassandraTable.java	41
cassandra-analytics-core/src/main/spark3/org/apache/cassandra/spark/sparksql/CassandraTableProvider.java	35
cassandra-analytics-core/src/main/spark3/org/apache/cassandra/spark/sparksql/LocalDataSource.java	21
cassandra-analytics-core/src/main/spark3/org/apache/cassandra/spark/sparksql/LocalPartitionSizeSource.java	17
cassandra-analytics-core/src/main/spark3/org/apache/cassandra/spark/sparksql/PartitionSizeIterator.java	57
cassandra-analytics-core/src/main/spark3/org/apache/cassandra/spark/sparksql/PartitionSizeTableProvider.java	130
cassandra-analytics-core/src/main/spark3/org/apache/cassandra/spark/sparksql/SparkRowIterator.java	55
cassandra-analytics-integration-framework/src/main/java/org/apache/cassandra/distributed/impl/CassandraCluster.java	273
cassandra-analytics-integration-framework/src/main/java/org/apache/cassandra/sidecar/testing/LocalhostResolver.java	45
cassandra-analytics-integration-framework/src/main/java/org/apache/cassandra/sidecar/testing/MtlsTestHelper.java	102
cassandra-analytics-integration-framework/src/main/java/org/apache/cassandra/sidecar/testing/QualifiedName.java	61
cassandra-analytics-integration-framework/src/main/java/org/apache/cassandra/sidecar/testing/SharedClusterIntegrationTestBase.java	568
cassandra-analytics-integration-framework/src/main/java/org/apache/cassandra/sidecar/testing/SharedExecutorNettyOptions.java	36
cassandra-analytics-integration-framework/src/main/java/org/apache/cassandra/sidecar/testing/TemporaryCqlSessionProvider.java	119
cassandra-analytics-integration-framework/src/main/java/org/apache/cassandra/testing/ClusterBuilderConfiguration.java	76
cassandra-analytics-integration-framework/src/main/java/org/apache/cassandra/testing/IClusterExtension.java	17
cassandra-analytics-integration-framework/src/main/java/org/apache/cassandra/testing/IsolatedDTestClassLoaderWrapper.java	149
cassandra-analytics-integration-framework/src/main/java/org/apache/cassandra/testing/Partitioner.java	26
cassandra-analytics-integration-framework/src/main/java/org/apache/cassandra/testing/TestTokenSupplier.java	76
cassandra-analytics-integration-framework/src/main/java/org/apache/cassandra/testing/TestUtils.java	61
cassandra-analytics-integration-framework/src/main/java/org/apache/cassandra/testing/TestVersion.java	20
cassandra-analytics-integration-framework/src/main/java/org/apache/cassandra/testing/TestVersionSupplier.java	19
cassandra-analytics-integration-framework/src/main/java/org/apache/cassandra/testing/utils/ClusterUtils.java	112
cassandra-analytics-integration-framework/src/main/java/org/apache/cassandra/testing/utils/WithProperties.java	29
cassandra-analytics-integration-framework/src/main/java/org/apache/cassandra/testing/utils/tls/CertificateBuilder.java	182
cassandra-analytics-integration-framework/src/main/java/org/apache/cassandra/testing/utils/tls/CertificateBundle.java	80
cassandra-analytics-sidecar-client/src/main/java/org/apache/cassandra/clients/ExecutorHolder.java	15
cassandra-analytics-sidecar-client/src/main/java/org/apache/cassandra/clients/Sidecar.java	289
cassandra-analytics-sidecar-client/src/main/java/org/apache/cassandra/clients/SidecarStreamConsumerAdapter.java	65
cassandra-analytics-sidecar-client/src/main/java/org/apache/cassandra/spark/validation/KeyStoreValidation.java	89
cassandra-analytics-sidecar-client/src/main/java/org/apache/cassandra/spark/validation/StartupValidation.java	18
cassandra-analytics-sidecar-client/src/main/java/org/apache/cassandra/spark/validation/StartupValidator.java	73
cassandra-analytics-sidecar-client/src/main/java/org/apache/cassandra/spark/validation/TrustStoreValidation.java	67
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/config/SchemaFeature.java	39
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/config/SchemaFeatureSet.java	32
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/SparkSqlTypeConverter.java	40
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/BinaryFeatures.java	44
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/DecimalFeatures.java	12
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/Empty.java	34
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/IntFeatures.java	30
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/LongFeatures.java	30
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/NotImplementedFeatures.java	18
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/SparkAscii.java	8
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/SparkBigInt.java	8
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/SparkBlob.java	8
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/SparkBoolean.java	33
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/SparkCounter.java	8
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/SparkDate.java	54
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/SparkDecimal.java	44
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/SparkDouble.java	34
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/SparkDuration.java	49
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/SparkFloat.java	34
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/SparkInet.java	32
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/SparkInt.java	8
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/SparkSmallInt.java	34
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/SparkText.java	8
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/SparkTime.java	8
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/SparkTimeUUID.java	8
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/SparkTimestamp.java	37
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/SparkTinyInt.java	34
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/SparkType.java	92
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/SparkUUID.java	8
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/SparkVarChar.java	8
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/SparkVarInt.java	49
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/StringFeatures.java	55
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/UUIDFeatures.java	15
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/complex/CollectionFeatures.java	30
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/complex/MapFeatures.java	13
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/complex/SparkFrozen.java	53
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/complex/SparkList.java	91
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/complex/SparkMap.java	108
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/complex/SparkSet.java	17
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/complex/SparkTuple.java	108
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/complex/SparkUdt.java	139
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/sparksql/LastModifiedTimestampDecorator.java	38
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/sparksql/RowBuilderDecorator.java	81
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/utils/FastThreadLocalUtf8Decoder.java	37
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/utils/SparkClassLoaderOverride.java	48
cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/utils/TemporaryDirectory.java	23
cassandra-analytics-spark-converter/src/main/scala-2.11-spark-2/org/apache/cassandra/spark/utils/ScalaConversionUtils.java	27
cassandra-analytics-spark-converter/src/main/scala-2.11-spark-2/org/apache/cassandra/spark/utils/SparkTypeUtils.java	28
cassandra-analytics-spark-converter/src/main/scala-2.12-spark-2/org/apache/cassandra/spark/utils/ScalaConversionUtils.java	27
cassandra-analytics-spark-converter/src/main/scala-2.12-spark-2/org/apache/cassandra/spark/utils/SparkTypeUtils.java	28
cassandra-analytics-spark-converter/src/main/scala-2.12-spark-3/org/apache/cassandra/spark/utils/ScalaConversionUtils.java	27
cassandra-analytics-spark-converter/src/main/scala-2.12-spark-3/org/apache/cassandra/spark/utils/SparkTypeUtils.java	24
cassandra-analytics-spark-converter/src/main/scala-2.13-spark-3/org/apache/cassandra/spark/utils/ScalaConversionUtils.java	27
cassandra-analytics-spark-converter/src/main/scala-2.13-spark-3/org/apache/cassandra/spark/utils/SparkTypeUtils.java	24
cassandra-analytics-spark-four-zero-converter/src/main/java/org/apache/cassandra/spark/data/converter/SparkSqlTypeConverterImplementation.java	133
cassandra-avro-converter/src/main/java/org/apache/cassandra/cdc/avro/AvroConstants.java	38
cassandra-avro-converter/src/main/java/org/apache/cassandra/cdc/avro/AvroSchemas.java	143
cassandra-avro-converter/src/main/java/org/apache/cassandra/cdc/avro/CqlToAvroSchemaConverter.java	44
cassandra-bridge/src/main/java/org/apache/cassandra/analytics/reader/common/IndexIterator.java	142
cassandra-bridge/src/main/java/org/apache/cassandra/analytics/reader/common/RawInputStream.java	165
cassandra-bridge/src/main/java/org/apache/cassandra/bridge/BaseCassandraBridgeFactory.java	123
cassandra-bridge/src/main/java/org/apache/cassandra/bridge/BloomFilter.java	14
cassandra-bridge/src/main/java/org/apache/cassandra/bridge/CassandraBridge.java	461
cassandra-bridge/src/main/java/org/apache/cassandra/bridge/CdcBridge.java	53
cassandra-bridge/src/main/java/org/apache/cassandra/bridge/PostDelegationClassLoader.java	37
cassandra-bridge/src/main/java/org/apache/cassandra/bridge/Tokenizer.java	7
cassandra-bridge/src/testFixtures/java/org/apache/cassandra/spark/CommonTestUtils.java	15
cassandra-four-zero-avro-converter/src/main/java/org/apache/cassandra/cdc/avro/CqlToAvroSchemaConverterImplementation.java	293
cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/bridge/CassandraBridgeImplementation.java	650
cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/bridge/CdcBridgeImplementation.java	303
cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/bridge/SSTableWriterImplementation.java	123
cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/cdc/FourZeroCommitLog.java	69
cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/cdc/FourZeroMutation.java	14
cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/cdc/msg/FourZeroCdcEventBuilder.java	302
cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/cdc/msg/FourZeroRangeTombstoneBuilder.java	65
cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/cdc/scanner/CdcSortedStreamScanner.java	201
cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/cdc/scanner/HybridUnfilteredPartitionIterator.java	42
cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/db/commitlog/BufferingCommitLogReader.java	673
cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/db/commitlog/FourZeroPartitionUpdateWrapper.java	33
cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/db/commitlog/SeekableCommitLogSegmentReader.java	147
cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/io/sstable/SSTableTombstoneWriter.java	319
cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/io/util/CdcRandomAccessReader.java	181
cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/spark/reader/AbstractStreamScanner.java	325
cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/spark/reader/CompactionStreamScanner.java	120
cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/spark/reader/CompressedRawInputStream.java	208
cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/spark/reader/CompressionMetadata.java	71
cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/spark/reader/CompressionUtils.java	52
cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/spark/reader/IndexDbUtils.java	95
cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/spark/reader/IndexReader.java	227
cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/spark/reader/ReaderUtils.java	472
cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/spark/reader/SSTableCache.java	163
cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/spark/reader/SSTableReader.java	708
cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/spark/reader/Scannable.java	6
cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/spark/reader/SummaryDbUtils.java	134
cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/utils/CompressionUtilImplementation.java	57
cassandra-four-zero-types/src/main/java/org/apache/cassandra/bridge/CassandraSchema.java	327
cassandra-four-zero-types/src/main/java/org/apache/cassandra/bridge/CassandraTypesImplementation.java	283
cassandra-four-zero-types/src/main/java/org/apache/cassandra/bridge/CollectionElement.java	20
cassandra-four-zero-types/src/main/java/org/apache/cassandra/cql3/functions/types/TupleHelper.java	30
cassandra-four-zero-types/src/main/java/org/apache/cassandra/cql3/functions/types/UserTypeHelper.java	31
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/CqlType.java	138
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/NativeType.java	70
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/complex/CqlCollection.java	176
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/complex/CqlFrozen.java	132
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/complex/CqlList.java	93
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/complex/CqlMap.java	106
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/complex/CqlSet.java	92
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/complex/CqlTuple.java	135
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/complex/CqlUdt.java	358
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/types/Ascii.java	23
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/types/BigInt.java	29
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/types/BinaryBased.java	5
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/types/Blob.java	36
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/types/Boolean.java	40
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/types/Counter.java	16
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/types/Date.java	46
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/types/Decimal.java	40
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/types/Double.java	35
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/types/Duration.java	138
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/types/Empty.java	39
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/types/Float.java	35
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/types/Inet.java	38
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/types/Int.java	35
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/types/LongBased.java	11
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/types/SmallInt.java	35
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/types/StringBased.java	17
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/types/Text.java	23
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/types/Time.java	29
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/types/TimeUUID.java	29
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/types/Timestamp.java	34
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/types/TinyInt.java	35
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/types/UUID.java	34
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/types/VarChar.java	23
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/types/VarInt.java	36
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/reader/ComplexTypeBuffer.java	77
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/reader/ListBuffer.java	8
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/reader/MapBuffer.java	20
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/reader/SchemaBuilder.java	495
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/reader/SetBuffer.java	14
cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/reader/UdtBuffer.java	8
cassandra-four-zero-types/src/main/java/org/apache/cassandra/utils/ColumnTypes.java	44
cassandra-four-zero-types/src/main/java/org/apache/cassandra/utils/TokenUtils.java	35
ide/idea/Project_Default.xml	133
ide/idea/codeStyleSettings.xml	331