Path	Lines of Code
cassandra-bridge/src/main/java/org/apache/cassandra/bridge/BigNumberConfig.java	27
cassandra-bridge/src/main/java/org/apache/cassandra/bridge/BigNumberConfigImpl.java	140
cassandra-bridge/src/main/java/org/apache/cassandra/bridge/CassandraBridge.java	373
cassandra-bridge/src/main/java/org/apache/cassandra/bridge/CassandraVersion.java	36
cassandra-bridge/src/main/java/org/apache/cassandra/bridge/RangeTombstone.java	21
cassandra-bridge/src/main/java/org/apache/cassandra/bridge/RowBufferMode.java	6
cassandra-bridge/src/main/java/org/apache/cassandra/bridge/SSTableWriter.java	8
cassandra-bridge/src/main/java/org/apache/cassandra/bridge/TokenRange.java	106
cassandra-bridge/src/main/java/org/apache/cassandra/spark/cdc/CommitLog.java	101
cassandra-bridge/src/main/java/org/apache/cassandra/spark/cdc/CommitLogProvider.java	6
cassandra-bridge/src/main/java/org/apache/cassandra/spark/cdc/IPartitionUpdateWrapper.java	6
cassandra-bridge/src/main/java/org/apache/cassandra/spark/cdc/TableIdLookup.java	9
cassandra-bridge/src/main/java/org/apache/cassandra/spark/cdc/watermarker/DoNothingWatermarker.java	50
cassandra-bridge/src/main/java/org/apache/cassandra/spark/cdc/watermarker/Watermarker.java	18
cassandra-bridge/src/main/java/org/apache/cassandra/spark/config/SchemaFeature.java	38
cassandra-bridge/src/main/java/org/apache/cassandra/spark/config/SchemaFeatureSet.java	122
cassandra-bridge/src/main/java/org/apache/cassandra/spark/data/CqlField.java	338
cassandra-bridge/src/main/java/org/apache/cassandra/spark/data/CqlTable.java	269
cassandra-bridge/src/main/java/org/apache/cassandra/spark/data/DataLayer.java	206
cassandra-bridge/src/main/java/org/apache/cassandra/spark/data/FileType.java	53
cassandra-bridge/src/main/java/org/apache/cassandra/spark/data/IncompleteSSTableException.java	17
cassandra-bridge/src/main/java/org/apache/cassandra/spark/data/ReplicationFactor.java	166
cassandra-bridge/src/main/java/org/apache/cassandra/spark/data/SSTable.java	62
cassandra-bridge/src/main/java/org/apache/cassandra/spark/data/SSTablesSupplier.java	12
cassandra-bridge/src/main/java/org/apache/cassandra/spark/data/partitioner/CassandraInstance.java	86
cassandra-bridge/src/main/java/org/apache/cassandra/spark/data/partitioner/MurmurHash.java	100
cassandra-bridge/src/main/java/org/apache/cassandra/spark/data/partitioner/Partitioner.java	67
cassandra-bridge/src/main/java/org/apache/cassandra/spark/exceptions/TransportFailureException.java	64
cassandra-bridge/src/main/java/org/apache/cassandra/spark/reader/EmptyStreamScanner.java	23
cassandra-bridge/src/main/java/org/apache/cassandra/spark/reader/Rid.java	170
cassandra-bridge/src/main/java/org/apache/cassandra/spark/reader/SparkSSTableReader.java	18
cassandra-bridge/src/main/java/org/apache/cassandra/spark/reader/StreamScanner.java	10
cassandra-bridge/src/main/java/org/apache/cassandra/spark/reader/common/AbstractCompressionMetadata.java	53
cassandra-bridge/src/main/java/org/apache/cassandra/spark/reader/common/BigLongArray.java	50
cassandra-bridge/src/main/java/org/apache/cassandra/spark/reader/common/ChunkCorruptException.java	9
cassandra-bridge/src/main/java/org/apache/cassandra/spark/reader/common/RawInputStream.java	165
cassandra-bridge/src/main/java/org/apache/cassandra/spark/reader/common/SSTableStreamException.java	31
cassandra-bridge/src/main/java/org/apache/cassandra/spark/sparksql/Cell.java	21
cassandra-bridge/src/main/java/org/apache/cassandra/spark/sparksql/CellTombstonesInComplexDecorator.java	65
cassandra-bridge/src/main/java/org/apache/cassandra/spark/sparksql/LastModifiedTimestampDecorator.java	38
cassandra-bridge/src/main/java/org/apache/cassandra/spark/sparksql/NoMatchFoundException.java	11
cassandra-bridge/src/main/java/org/apache/cassandra/spark/sparksql/RangeTombstone.java	11
cassandra-bridge/src/main/java/org/apache/cassandra/spark/sparksql/RangeTombstoneDecorator.java	58
cassandra-bridge/src/main/java/org/apache/cassandra/spark/sparksql/RangeTombstoneMarker.java	23
cassandra-bridge/src/main/java/org/apache/cassandra/spark/sparksql/RowBuilder.java	19
cassandra-bridge/src/main/java/org/apache/cassandra/spark/sparksql/RowBuilderDecorator.java	81
cassandra-bridge/src/main/java/org/apache/cassandra/spark/sparksql/Tombstone.java	13
cassandra-bridge/src/main/java/org/apache/cassandra/spark/sparksql/TombstonesInComplex.java	19
cassandra-bridge/src/main/java/org/apache/cassandra/spark/sparksql/UpdateFlagDecorator.java	36
cassandra-bridge/src/main/java/org/apache/cassandra/spark/sparksql/UpdatedFieldsIndicatorDecorator.java	45
cassandra-bridge/src/main/java/org/apache/cassandra/spark/sparksql/filters/CdcOffset.java	83
cassandra-bridge/src/main/java/org/apache/cassandra/spark/sparksql/filters/CdcOffsetFilter.java	51
cassandra-bridge/src/main/java/org/apache/cassandra/spark/sparksql/filters/PartitionKeyFilter.java	53
cassandra-bridge/src/main/java/org/apache/cassandra/spark/sparksql/filters/PruneColumnFilter.java	23
cassandra-bridge/src/main/java/org/apache/cassandra/spark/sparksql/filters/SparkRangeFilter.java	36
cassandra-bridge/src/main/java/org/apache/cassandra/spark/stats/Stats.java	229
cassandra-bridge/src/main/java/org/apache/cassandra/spark/utils/ArrayUtils.java	20
cassandra-bridge/src/main/java/org/apache/cassandra/spark/utils/ByteBufferUtils.java	170
cassandra-bridge/src/main/java/org/apache/cassandra/spark/utils/ColumnTypes.java	92
cassandra-bridge/src/main/java/org/apache/cassandra/spark/utils/ComparisonUtils.java	170
cassandra-bridge/src/main/java/org/apache/cassandra/spark/utils/FutureUtils.java	137
cassandra-bridge/src/main/java/org/apache/cassandra/spark/utils/IOUtils.java	75
cassandra-bridge/src/main/java/org/apache/cassandra/spark/utils/LoggerHelper.java	113
cassandra-bridge/src/main/java/org/apache/cassandra/spark/utils/MapUtils.java	112
cassandra-bridge/src/main/java/org/apache/cassandra/spark/utils/RandomUtils.java	66
cassandra-bridge/src/main/java/org/apache/cassandra/spark/utils/SparkClassLoaderOverride.java	48
cassandra-bridge/src/main/java/org/apache/cassandra/spark/utils/TemporaryDirectory.java	23
cassandra-bridge/src/main/java/org/apache/cassandra/spark/utils/ThrowableUtils.java	32
cassandra-bridge/src/main/java/org/apache/cassandra/spark/utils/Throwing.java	44
cassandra-bridge/src/main/java/org/apache/cassandra/spark/utils/TimeProvider.java	7
cassandra-bridge/src/main/java/org/apache/cassandra/spark/utils/streaming/SSTableInputStream.java	412
cassandra-bridge/src/main/java/org/apache/cassandra/spark/utils/streaming/SSTableSource.java	31
cassandra-bridge/src/main/java/org/apache/cassandra/spark/utils/streaming/StreamBuffer.java	46
cassandra-bridge/src/main/java/org/apache/cassandra/spark/utils/streaming/StreamConsumer.java	7
cassandra-bridge/src/main/scala-2.11-spark-2/org/apache/cassandra/spark/utils/ScalaConversionUtils.java	27
cassandra-bridge/src/main/scala-2.12-spark-2/org/apache/cassandra/spark/utils/ScalaConversionUtils.java	27
cassandra-bridge/src/main/scala-2.12-spark-3/org/apache/cassandra/spark/utils/ScalaConversionUtils.java	27
cassandra-bridge/src/main/scala-2.13-spark-3/org/apache/cassandra/spark/utils/ScalaConversionUtils.java	27