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" ] "[v1/src/main/java/com/google/cloud/teleport/templates/common/SpannerConverters.java]" -- "[v1/src/main/java/com/google/cloud/teleport/templates/TextToSpanner.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/schema/CassandraSchemaDiscovery.java]" -- "[v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/mappings/CassandraMappings.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[v1/src/main/java/com/google/cloud/teleport/templates/TextToSpanner.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/TextImportPipeline.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[v1/src/main/java/com/google/cloud/teleport/templates/common/SpannerConverters.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/TextImportTransform.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/dml/CassandraTypeHandler.java]" -- "[v2/spanner-custom-shard/src/main/java/com/custom/CustomTransformationWithCassandraForIT.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[v1/src/main/java/com/google/cloud/teleport/templates/TextToSpanner.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/ExportTransform.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[v1/src/main/java/com/google/cloud/teleport/templates/TextToSpanner.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/BuildReadFromTableOperations.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[v1/src/main/java/com/google/cloud/teleport/spanner/TextImportPipeline.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/ExportTransform.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/TemplatesReleaseMojo.java]" -- "[plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/TemplatesStageMojo.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[v1/src/main/java/com/google/cloud/teleport/spanner/TextImportTransform.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/BuildReadFromTableOperations.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/TemplatesRunMojo.java]" -- "[plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/TemplatesStageMojo.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[v1/src/main/java/com/google/cloud/teleport/spanner/ddl/InformationSchemaScanner.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/DdlToAvroSchemaConverter.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[v1/src/main/java/com/google/cloud/teleport/templates/common/SpannerConverters.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/TextImportPipeline.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/TemplatesRunMojo.java]" -- "[plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/TemplatesReleaseMojo.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[v1/src/main/java/com/google/cloud/teleport/templates/TextToSpanner.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/TextImportTransform.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[v1/src/main/java/com/google/cloud/teleport/templates/common/SpannerConverters.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/ExportTransform.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/MigrateTableTransform.java]" -- "[v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/options/SourceDbToSpannerOptions.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/iowrapper/CassandraTableReaderFactoryCassandraIoImpl.java]" -- "[v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/iowrapper/CassandraDataSource.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[v1/src/main/java/com/google/cloud/teleport/spanner/DdlToAvroSchemaConverter.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/AvroSchemaToDdlConverter.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[v1/src/main/java/com/google/cloud/teleport/templates/common/SpannerConverters.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/BuildReadFromTableOperations.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[v1/src/main/java/com/google/cloud/teleport/spanner/TextImportTransform.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/TextImportPipeline.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/dml/CassandraTypeHandler.java]" -- "[v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/dml/CassandraDMLGenerator.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[v2/spanner-custom-shard/src/main/java/com/custom/CustomTransformationWithCassandraForIT.java]" -- "[v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/dml/CassandraDMLGenerator.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[v1/src/main/java/com/google/cloud/teleport/spanner/ExportTransform.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/BuildReadFromTableOperations.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/rowmapper/CassandraRowValueArrayMapper.java]" -- "[v2/sourcedb-to-spanner/src/main/java/com/google/cloud/teleport/v2/source/reader/io/cassandra/mappings/CassandraMappingsProvider.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[v1/src/main/java/com/google/cloud/teleport/spanner/TextImportTransform.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/ExportTransform.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[v1/src/main/java/com/google/cloud/teleport/spanner/TextImportPipeline.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/BuildReadFromTableOperations.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/estimator/BytesThroughputEstimator.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerTransformRegistrar.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/package-info.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/Transaction.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerReadSchemaTransformProvider.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/NaiveSpannerRead.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/restriction/TimestampRangeTracker.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/dao/ChangeStreamResultSet.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerSchema.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/BatchSpannerRead.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/model/InitialPartition.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/ChangeStreamsConstants.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerSchemaRetrievalException.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerIO.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/estimator/ThroughputEstimator.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/Transaction.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/model/ChangeStreamRecordMetadata.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/ChangeStreamMetrics.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/model/PartitionMetadata.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/estimator/ThroughputEstimator.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/dofn/ReadChangeStreamPartitionDoFn.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/dofn/DetectNewPartitionsDoFn.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/dofn/ReadChangeStreamPartitionDoFn.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/dao/PartitionMetadataAdminDao.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/restriction/ReadChangeStreamPartitionRangeTracker.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/model/package-info.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/estimator/EncodingException.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerSchemaRetrievalException.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/PostgresChangeEventSequence.java]" -- "[it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/spanner/SpannerResourceManager.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/restriction/ReadChangeStreamPartitionRangeTracker.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/model/DataChangeRecord.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/MutationKeyEncoder.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/TextImportTransform.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/dofn/ReadChangeStreamPartitionDoFn.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/dofn/PostProcessingMetricsDoFn.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/dofn/ReadChangeStreamPartitionDoFn.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/action/DetectNewPartitionsAction.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/model/ChildPartitionsRecord.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerAccessor.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/MutationCellCounter.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/ImportTransform.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/ChangeStreamsConstants.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/NaiveSpannerRead.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/restriction/package-info.java]" -- "[v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/changestreams/restriction/TimestampUtils.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; }