graph G { compound="true" rankdir="TB" bgcolor="white" fontname="Tahoma" node [ fixedsize="false" fontname="Tahoma" color="white" fillcolor="deepskyblue2" fontcolor="black" shape="box" style="filled" penwidth="1.0" ] edge [ fontname="Arial" color="#00688b" fontcolor="black" fontsize="12" arrowsize="0.5" penwidth="1.0" ] "[cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/reader/SchemaBuilder.java]" -- "[cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/streaming/BufferingInputStream.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-avro-converter/src/main/java/org/apache/cassandra/cdc/avro/CqlToAvroSchemaConverter.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/AvroGenericRecordTransformer.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/Preconditions.java]" -- "[cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/msg/CdcEventBuilder.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/msg/CdcEventBuilder.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/RecordReader.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/TableIdentifier.java]" -- "[cassandra-analytics-cdc-codec/src/main/resources/cdc_bytes.avsc]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/TableIdentifier.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/AvroSerializer.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/msg/Value.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/kafka/KafkaOptions.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/msg/CdcEventBuilder.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/kafka/TopicSupplier.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/kafka/KafkaOptions.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/kafka/EventHasher.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/json/JsonSerializer.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/RecordReader.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/msg/CdcEnvelope.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/CdcLogger.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/schemastore/SchemaStorePublisherFactory.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/TypeConversionRegistry.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/schemastore/SchemaStorePublisherFactory.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/kafka/KafkaStats.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/msg/Value.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/AvroSerializer.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/Preconditions.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/CdcEventTransformer.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-avro-converter/src/main/java/org/apache/cassandra/cdc/avro/CqlToAvroSchemaConverter.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/CdcEventUtils.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/msg/FieldValue.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/AvroGenericRecordTransformer.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-cdc-sidecar/src/main/java/org/apache/cassandra/cdc/sidecar/SidecarCdcOptions.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/CdcLogMode.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-avro-converter/src/main/java/org/apache/cassandra/cdc/avro/CqlToAvroSchemaConverter.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/TypeConversion.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-spark-four-zero-converter/src/main/java/org/apache/cassandra/spark/data/converter/SparkSqlTypeConverterImplementation.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/schemastore/CachingSchemaStore.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/msg/CdcEventBuilder.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/kafka/EventHasher.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/Preconditions.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/kafka/TopicSupplier.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-bridge/src/main/java/org/apache/cassandra/bridge/BaseCassandraBridgeFactory.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/schemastore/CachingSchemaStore.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/TypeConversionRegistry.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/CdcLogger.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/kafka/RecordProducer.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/AvroBaseRecordTransformer.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-bridge/src/main/java/org/apache/cassandra/bridge/CdcBridge.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/AvroSerializer.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/msg/Value.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/kafka/AvroGenericRecordSerializer.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/MapUtils.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/CdcLogMode.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/TableIdentifier.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/schemastore/SchemaStoreStats.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/kafka/RecordProducer.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/CdcLogger.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/AvroGenericRecordTransformer.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/AvroByteRecordTransformer.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/json/AvroJsonTransformer.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/CdcLogMode.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-avro-converter/src/main/java/org/apache/cassandra/cdc/avro/CqlToAvroSchemaConverter.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/kafka/KafkaStats.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/json/CdcGenericData.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/AvroDataUtils.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/kafka/EventHasher.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/AvroGenericRecordTransformer.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-cdc/src/main/java/org/apache/cassandra/cdc/msg/jdk/CdcMessage.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/kafka/KafkaPublisher.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-bridge/src/main/java/org/apache/cassandra/bridge/BaseCassandraBridgeFactory.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/TypeConversionRegistry.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/ArrayUtils.java]" -- "[cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/msg/Value.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/TypeConversionRegistry.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/AvroBaseRecordTransformer.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-bridge/src/main/java/org/apache/cassandra/bridge/CdcBridge.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/json/CdcGenericData.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-four-zero-avro-converter/src/main/java/org/apache/cassandra/cdc/avro/CqlToAvroSchemaConverterImplementation.java]" -- "[cassandra-analytics-spark-four-zero-converter/src/main/java/org/apache/cassandra/spark/data/converter/SparkSqlTypeConverterImplementation.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-cdc-codec/src/main/resources/cdc_bytes.avsc]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/schemastore/TableSchemaPublisher.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/ByteBufferUtils.java]" -- "[cassandra-analytics-cdc-codec/src/main/resources/cdc_bytes.avsc]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/kafka/EventHasher.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/CdcEventUtils.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/kafka/KafkaPublisher.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/CdcEventUtils.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-bridge/src/main/java/org/apache/cassandra/bridge/BaseCassandraBridgeFactory.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/CdcEventAvroEncoder.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/schemastore/CachingSchemaStore.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/msg/CdcEnvelope.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/schemastore/SchemaStorePublisherFactory.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/TypeConversion.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/TableIdentifier.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/AvroDataUtils.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/kafka/KafkaPublisher.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/AvroByteRecordTransformer.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; }