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