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" ] "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableAction.java]" -- "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseAction.java]" [label=" 6 ", penwidth="6", color="#00688bB7"]; "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseAction.java]" -- "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseAction.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[paimon-core/src/main/java/org/apache/paimon/table/ChangelogValueCountFileStoreTable.java]" -- "[paimon-core/src/main/java/org/apache/paimon/table/ChangelogWithKeyFileStoreTable.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java]" -- "[paimon-core/src/main/java/org/apache/paimon/table/ChangelogWithKeyFileStoreTable.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlTableSchemaBuilder.java]" -- "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlDebeziumJsonEventParser.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseAction.java]" -- "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlDebeziumJsonEventParser.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseAction.java]" -- "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableAction.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java]" -- "[paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[paimon-core/src/main/java/org/apache/paimon/table/ChangelogValueCountFileStoreTable.java]" -- "[paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseAction.java]" -- "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlActionUtils.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java]" -- "[paimon-core/src/main/java/org/apache/paimon/table/ChangelogValueCountFileStoreTable.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseAction.java]" -- "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSchema.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java]" -- "[paimon-core/src/main/java/org/apache/paimon/table/ChangelogValueCountFileStoreTable.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionFactory.java]" -- "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseAction.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionFactory.java]" -- "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseAction.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java]" -- "[paimon-core/src/main/java/org/apache/paimon/schema/SchemaValidation.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreRead.java]" -- "[paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalog.java]" -- "[paimon-core/src/main/java/org/apache/paimon/catalog/Catalog.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableAction.java]" -- "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseAction.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java]" -- "[paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseAction.java]" -- "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlDebeziumJsonEventParser.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSchema.java]" -- "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlDebeziumJsonEventParser.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java]" -- "[paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlTableSchemaBuilder.java]" -- "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseAction.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableAction.java]" -- "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlActionUtils.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/UpdatedDataFieldsProcessFunction.java]" -- "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/MultiTableUpdatedDataFieldsProcessFunction.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[paimon-core/src/main/java/org/apache/paimon/table/system/AuditLogTable.java]" -- "[paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalog.java]" -- "[paimon-core/src/main/java/org/apache/paimon/catalog/Catalog.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[paimon-core/src/main/java/org/apache/paimon/schema/SchemaValidation.java]" -- "[paimon-core/src/main/java/org/apache/paimon/table/ChangelogWithKeyFileStoreTable.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java]" -- "[paimon-core/src/main/java/org/apache/paimon/schema/SchemaValidation.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableAction.java]" -- "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableAction.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/RichCdcMultiplexRecordEventParser.java]" -- "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlDebeziumJsonEventParser.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseAction.java]" -- "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableAction.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSchema.java]" -- "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlActionUtils.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java]" -- "[paimon-core/src/main/java/org/apache/paimon/table/ChangelogWithKeyFileStoreTable.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/canal/CanalRecordParser.java]" -- "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlDebeziumJsonEventParser.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseActionFactory.java]" -- "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionFactory.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionFactory.java]" -- "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSchema.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[paimon-core/src/main/java/org/apache/paimon/table/system/BucketsTable.java]" -- "[paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecordStoreMultiWriteOperator.java]" -- "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreSinkWriteImpl.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[paimon-core/src/main/java/org/apache/paimon/table/source/InnerStreamTableScanImpl.java]" -- "[paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/DropPartitionAction.java]" -- "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseAction.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java]" -- "[paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[paimon-core/src/main/java/org/apache/paimon/table/system/BucketsTable.java]" -- "[paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java]" -- "[paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/AppendOnlyTableCompactionWorkerOperator.java]" -- "[paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyCompactionTask.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[paimon-core/src/main/java/org/apache/paimon/catalog/Catalog.java]" -- "[paimon-core/src/main/java/org/apache/paimon/catalog/AbstractCatalog.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/mapred/PaimonInputFormat.java]" -- "[paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/HiveSchema.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecordStoreMultiWriteOperator.java]" -- "[paimon-core/src/main/java/org/apache/paimon/table/sink/TableWriteImpl.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/CheckpointEvent.java]" -- "[paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/AlignedContinuousFileSplitEnumerator.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; }