Path	Lines of Code
cassandra-analytics-core/src/main/java/org/apache/cassandra/bridge/CassandraBridgeFactory.java	95
cassandra-analytics-core/src/main/java/org/apache/cassandra/bridge/CassandraVersionFeatures.java	134
cassandra-analytics-core/src/main/java/org/apache/cassandra/bridge/PostDelegationClassLoader.java	39
cassandra-analytics-core/src/main/java/org/apache/cassandra/clients/ExecutorHolder.java	15
cassandra-analytics-core/src/main/java/org/apache/cassandra/clients/Sidecar.java	296
cassandra-analytics-core/src/main/java/org/apache/cassandra/clients/SidecarInstanceImpl.java	68
cassandra-analytics-core/src/main/java/org/apache/cassandra/clients/SidecarStreamConsumerAdapter.java	65
cassandra-analytics-core/src/main/java/org/apache/cassandra/secrets/SecretsProvider.java	27
cassandra-analytics-core/src/main/java/org/apache/cassandra/secrets/SslConfig.java	308
cassandra-analytics-core/src/main/java/org/apache/cassandra/secrets/SslConfigSecretsProvider.java	151
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/KryoRegister.java	69
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/BulkSparkConf.java	386
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/BulkWriteValidator.java	129
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/BulkWriterContext.java	10
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	136
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/CassandraBulkWriterContext.java	132
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/CassandraClusterInfo.java	453
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/CassandraContext.java	66
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/CassandraJobInfo.java	85
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/CassandraRingMonitor.java	97
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/CassandraSchemaInfo.java	15
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/ClusterInfo.java	21
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/CommitCoordinator.java	179
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	39
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/CqlTableInfoProvider.java	122
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/DataTransferApi.java	37
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/InstanceAvailability.java	18
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/JobInfo.java	23
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/LoadNotSupportedException.java	8
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/RecordWriter.java	188
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/RingInstance.java	100
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/SSTableWriter.java	141
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	6
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/SidecarDataTransferApi.java	117
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/SqlToCqlTypeConverter.java	651
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/StreamError.java	12
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/StreamResult.java	34
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/StreamSession.java	252
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	227
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	191
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/Tokenizer.java	23
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/WriterOption.java	5
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/WriterOptions.java	29
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/token/CassandraRing.java	196
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/token/ConsistencyLevel.java	139
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/token/RangeUtils.java	91
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/token/ReplicaAwareFailureHandler.java	84
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/SbwJavaSerializer.java	73
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/util/SbwKryoRegistrator.java	46
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/util/ThreadUtil.java	27
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/cdc/CdcCellIterator.java	28
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/cdc/CdcRowIterator.java	30
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/cdc/watermarker/InMemoryWatermarker.java	217
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/MD5Hash.java	19
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/SSTables.java	14
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/client/ClientException.java	14
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/client/InstanceState.java	10
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/client/InstanceStatus.java	7
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/model/BulkFeatures.java	11
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/model/CassandraInstance.java	7
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/schema/BooleanType.java	27
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/schema/BytesType.java	31
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/schema/CollectionType.java	24
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/schema/ColumnType.java	9
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/schema/ColumnTypes.java	83
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	26
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/schema/IntegerType.java	21
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	21
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	24
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/schema/StringUuidType.java	22
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/common/schema/UuidType.java	31
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/BasicSupplier.java	22
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/CassandraDataLayer.java	1015
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/CassandraDataSourceHelper.java	85
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/DefaultSizing.java	14
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/FileSystemSSTable.java	72
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/FileSystemSource.java	121
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/LocalCommitLog.java	77
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/LocalDataLayer.java	395
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/PartitionedDataLayer.java	424
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/ReplicaSet.java	60
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/SidecarProvisionedSSTable.java	205
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/Sizing.java	5
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/partitioner/CassandraRing.java	258
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/partitioner/ConsistencyLevel.java	95
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/NotEnoughReplicasException.java	34
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/data/partitioner/TokenPartitioner.java	229
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/sparksql/AbstractSparkRowIterator.java	109
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/FullRowBuilder.java	107
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/sparksql/SparkCellIterator.java	302
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/utils/BuildInfo.java	77
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/utils/CqlUtils.java	228
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/Properties.java	38
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/utils/RangeUtils.java	110
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/TableIdentifier.java	49
cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/utils/UUIDs.java	56
cassandra-analytics-core/src/main/spark2/org/apache/cassandra/spark/sparksql/CassandraDataSource.java	168
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	48
cassandra-analytics-core/src/main/spark3/org/apache/cassandra/spark/sparksql/CassandraDataSource.java	23
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/CassandraMicroBatchStream.java	111
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	119
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	40
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/SparkRowIterator.java	148