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-analytics-cdc/src/main/java/org/apache/cassandra/cdc/msg/jdk/CdcMessage.java]" -- "[cassandra-analytics-cdc-sidecar/src/main/java/org/apache/cassandra/cdc/sidecar/SidecarCdcStats.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[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=" 2 ", penwidth="2", color="#00688b70"]; "[cassandra-analytics-cdc/src/main/java/org/apache/cassandra/cdc/msg/jdk/CdcMessage.java]" -- "[cassandra-analytics-cdc-sidecar/src/main/java/org/apache/cassandra/cdc/sidecar/SidecarCdcOptions.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[cassandra-analytics-cdc-codec/src/main/resources/cdc_generic_record.avsc]" -- "[cassandra-analytics-cdc-codec/src/main/resources/cdc_bytes.avsc]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[cassandra-analytics-cdc-codec/src/main/resources/cdc_generic_record.avsc]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/schemastore/TableSchemaPublisher.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[cassandra-analytics-cdc-sidecar/src/main/java/org/apache/cassandra/cdc/sidecar/SidecarCdcStats.java]" -- "[cassandra-analytics-cdc-sidecar/src/main/java/org/apache/cassandra/cdc/sidecar/SidecarCdcOptions.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/Bundle.java]" -- "[cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/CloudStorageStreamSession.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[cassandra-avro-converter/src/main/java/org/apache/cassandra/cdc/avro/AvroSchemas.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/AvroSchemas.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/schemastore/SchemaStoreStats.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-core/src/main/java/org/apache/cassandra/clients/AnalyticsSidecarClient.java]" -- "[cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/api/CommitLog.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/SSTablesBundler.java]" -- "[cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/CloudStorageStreamSession.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-sidecar-client/src/main/java/org/apache/cassandra/spark/validation/KeyStoreValidation.java]" -- "[cassandra-analytics-cdc-sidecar/src/main/java/org/apache/cassandra/cdc/sidecar/SidecarDownMonitor.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/KafkaPublisher.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/avro/AvroGenericRecordTransformer.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/avro/CdcEventAvroEncoder.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/KafkaCdcSerializer.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/types/Date.java]" -- "[cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/complex/CqlFrozen.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-cdc-codec/src/main/resources/cdc_generic_record.avsc]" -- "[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/cdc/api/CommitLogMarkers.java]" -- "[cassandra-analytics-cdc/src/main/java/org/apache/cassandra/cdc/msg/jdk/CdcMessage.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/complex/CqlFrozen.java]" -- "[cassandra-analytics-spark-converter/src/main/scala-2.12-spark-3/org/apache/cassandra/spark/utils/SparkTypeUtils.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/avro/RecordReader.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/MapUtils.java]" -- "[cassandra-analytics-cdc/src/main/java/org/apache/cassandra/cdc/msg/jdk/CdcMessage.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-common/src/main/java/org/apache/cassandra/spark/utils/Preconditions.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/json/JsonSerializer.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-spark-converter/src/main/scala-2.12-spark-3/org/apache/cassandra/spark/utils/SparkTypeUtils.java]" -- "[cassandra-analytics-spark-converter/src/main/scala-2.11-spark-2/org/apache/cassandra/spark/utils/SparkTypeUtils.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/CqlTable.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/TypeConversion.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/kafka/TopicSupplier.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/CdcEventAvroEncoder.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/reader/SchemaBuilder.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/schemastore/SchemaStorePublisherFactory.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/CdcLogger.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-bridge/src/main/java/org/apache/cassandra/bridge/BloomFilter.java]" -- "[cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/sparksql/AbstractSparkRowIterator.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-cdc-sidecar/src/main/java/org/apache/cassandra/cdc/sidecar/SidecarCdc.java]" -- "[cassandra-analytics-cdc-sidecar/src/main/java/org/apache/cassandra/cdc/sidecar/SidecarCdcStats.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-sidecar-client/src/main/java/org/apache/cassandra/clients/Sidecar.java]" -- "[cassandra-analytics-cdc/src/main/java/org/apache/cassandra/cdc/Cdc.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-sidecar-client/src/main/java/org/apache/cassandra/clients/Sidecar.java]" -- "[cassandra-analytics-cdc/src/main/java/org/apache/cassandra/cdc/CdcBuilder.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/schemastore/CachingSchemaStore.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/spark/reader/SummaryDbUtils.java]" -- "[cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/ByteBufferUtils.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/TypeConversion.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/EventHasher.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-avro-converter/src/main/java/org/apache/cassandra/cdc/avro/AvroConstants.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/AvroBaseRecordTransformer.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/spark/reader/SSTableCache.java]" -- "[cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/sparksql/filters/PartitionKeyFilter.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/CdcLogMode.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/schemastore/SchemaStoreStats.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/AvroByteRecordTransformer.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-core/src/main/java/org/apache/cassandra/clients/AnalyticsSidecarClient.java]" -- "[cassandra-analytics-cdc/src/main/java/org/apache/cassandra/cdc/CdcKryoRegister.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/types/Duration.java]" -- "[cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/data/NativeType.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/CdcEventAvroEncoder.java]" -- "[cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/AvroDataUtils.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/avro/CdcEventAvroEncoder.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/java/org/apache/cassandra/cdc/schemastore/SchemaStoreStats.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-sidecar-client/src/main/java/org/apache/cassandra/spark/validation/KeyStoreValidation.java]" -- "[cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/api/CommitLog.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-spark-converter/src/main/java/org/apache/cassandra/spark/data/converter/types/SparkDuration.java]" -- "[cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/CqlField.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/CassandraContext.java]" -- "[cassandra-analytics-cdc-sidecar/src/main/java/org/apache/cassandra/cdc/CassandraClientSource.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; }