apache / incubator-paimon
Temporal Dependencies

A temporal dependency occurs when developers change two or more files at the same time (i.e. they are a part of the same commit).


Files Most Frequently Changed Together (Top 50)

data...

Pairs # same commits # commits 1 # commits 2 latest commit
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		 6 10 (60%) 9 (66%) 2023-08-08
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		 4 28 (14%) 9 (44%) 2023-08-03
paimon-core/src/main/java/org/apache/paimon/table/ChangelogValueCountFileStoreTable.java
paimon-core/src/main/java/org/apache/paimon/table/ChangelogWithKeyFileStoreTable.java		 4 14 (28%) 18 (22%) 2023-08-07
paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java
paimon-core/src/main/java/org/apache/paimon/table/ChangelogWithKeyFileStoreTable.java		 4 34 (11%) 18 (22%) 2023-08-07
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		 4 4 (100%) 31 (12%) 2023-07-24
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		 4 28 (14%) 31 (12%) 2023-08-03
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		 4 28 (14%) 25 (16%) 2023-07-31
paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java
paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java		 4 17 (23%) 34 (11%) 2023-08-02
paimon-core/src/main/java/org/apache/paimon/table/ChangelogValueCountFileStoreTable.java
paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java		 4 14 (28%) 34 (11%) 2023-08-07
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		 4 28 (14%) 16 (25%) 2023-08-03
paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java
paimon-core/src/main/java/org/apache/paimon/table/ChangelogValueCountFileStoreTable.java		 4 17 (23%) 14 (28%) 2023-08-02
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		 4 28 (14%) 15 (26%) 2023-08-03
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java
paimon-core/src/main/java/org/apache/paimon/table/ChangelogValueCountFileStoreTable.java		 3 9 (33%) 14 (21%) 2023-08-07
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		 3 3 (100%) 28 (10%) 2023-08-03
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		 3 3 (100%) 9 (33%) 2023-08-03
paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java
paimon-core/src/main/java/org/apache/paimon/schema/SchemaValidation.java		 3 34 (8%) 16 (18%) 2023-08-07
paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreRead.java
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java		 3 10 (30%) 9 (33%) 2023-07-17
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		 3 30 (10%) 13 (23%) 2023-07-31
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		 3 25 (12%) 9 (33%) 2023-08-08
paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java		 3 17 (17%) 9 (33%) 2023-07-17
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		 3 9 (33%) 31 (9%) 2023-08-03
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		 3 15 (20%) 31 (9%) 2023-08-03
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java
paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java		 3 9 (33%) 34 (8%) 2023-08-07
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		 3 4 (75%) 28 (10%) 2023-07-18
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		 3 25 (12%) 16 (18%) 2023-08-08
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		 3 7 (42%) 5 (60%) 2023-08-07
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		 3 20 (15%) 9 (33%) 2023-08-07
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		 3 23 (13%) 13 (23%) 2023-07-31
paimon-core/src/main/java/org/apache/paimon/schema/SchemaValidation.java
paimon-core/src/main/java/org/apache/paimon/table/ChangelogWithKeyFileStoreTable.java		 3 16 (18%) 18 (16%) 2023-08-07
paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java
paimon-core/src/main/java/org/apache/paimon/schema/SchemaValidation.java		 3 9 (33%) 16 (18%) 2023-08-07
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		 3 25 (12%) 10 (30%) 2023-08-08
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		 3 3 (100%) 31 (9%) 2023-07-18
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		 3 28 (10%) 10 (30%) 2023-07-17
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		 3 15 (20%) 16 (18%) 2023-08-03
paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java
paimon-core/src/main/java/org/apache/paimon/table/ChangelogWithKeyFileStoreTable.java		 3 17 (17%) 18 (16%) 2023-08-02
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		 3 3 (100%) 31 (9%) 2023-07-24
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		 2 3 (66%) 3 (66%) 2023-07-17
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		 2 3 (66%) 15 (13%) 2023-08-03
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		 2 10 (20%) 9 (22%) 2023-07-17
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		 2 10 (20%) 14 (14%) 2023-08-04
paimon-core/src/main/java/org/apache/paimon/table/source/InnerStreamTableScanImpl.java
paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java		 2 12 (16%) 17 (11%) 2023-07-17
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		 2 9 (22%) 9 (22%) 2023-07-31
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		 2 9 (22%) 13 (15%) 2023-07-17
paimon-core/src/main/java/org/apache/paimon/table/system/BucketsTable.java
paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java		 2 10 (20%) 13 (15%) 2023-07-17
paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java
paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java		 2 17 (11%) 13 (15%) 2023-07-17
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		 2 5 (40%) 4 (50%) 2023-08-02
paimon-core/src/main/java/org/apache/paimon/catalog/Catalog.java
paimon-core/src/main/java/org/apache/paimon/catalog/AbstractCatalog.java		 2 13 (15%) 14 (14%) 2023-07-31
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		 2 13 (15%) 24 (8%) 2023-07-13
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		 2 10 (20%) 14 (14%) 2023-08-04
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		 2 2 (100%) 3 (66%) 2023-08-07
Dependencies between files in same commits
The number on the lines shows the number of shared commits.
G [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/KafkaSyncTableAction.java] [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/kafka/KafkaSyncDatabaseAction.java] [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] 6 [paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlDebeziumJsonEventParser.java] [paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlDebeziumJsonEventParser.java] [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] 3 [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/MySqlSyncDatabaseAction.java] [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] 3 [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] 4 [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] 4 [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/MySqlSyncTableAction.java] [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] 4 [paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlActionUtils.java] [paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlActionUtils.java] [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] 4 [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/MySqlSchema.java] [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] 4 [paimon-core/src/main/java/org/apache/paimon/table/ChangelogValueCountFileStoreTable.java] [paimon-core/src/main/java/org/apache/paimon/table/ChangelogValueCountFileStoreTable.java] [paimon-core/src/main/java/org/apache/paimon/table/ChangelogWithKeyFileStoreTable.java] [paimon-core/src/main/java/org/apache/paimon/table/ChangelogWithKeyFileStoreTable.java] [paimon-core/src/main/java/org/apache/paimon/table/ChangelogValueCountFileStoreTable.java]--[paimon-core/src/main/java/org/apache/paimon/table/ChangelogWithKeyFileStoreTable.java] 4 [paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java] [paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java] [paimon-core/src/main/java/org/apache/paimon/table/ChangelogValueCountFileStoreTable.java]--[paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java] 4 [paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java]--[paimon-core/src/main/java/org/apache/paimon/table/ChangelogWithKeyFileStoreTable.java] 4 [paimon-core/src/main/java/org/apache/paimon/schema/SchemaValidation.java] [paimon-core/src/main/java/org/apache/paimon/schema/SchemaValidation.java] [paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java]--[paimon-core/src/main/java/org/apache/paimon/schema/SchemaValidation.java] 3 [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/MySqlTableSchemaBuilder.java] [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] 3 [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] 4 [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] 3 [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] 3 [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] 3 [paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java] [paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java] [paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java]--[paimon-core/src/main/java/org/apache/paimon/table/ChangelogValueCountFileStoreTable.java] 4 [paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java]--[paimon-core/src/main/java/org/apache/paimon/table/ChangelogWithKeyFileStoreTable.java] 3 [paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java]--[paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java] 4 [paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java] [paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java] [paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java]--[paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java] 3 [paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java] [paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java] [paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java]--[paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java] 2 [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] 3 [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] 3 [paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java]--[paimon-core/src/main/java/org/apache/paimon/table/ChangelogValueCountFileStoreTable.java] 3 [paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java]--[paimon-core/src/main/java/org/apache/paimon/table/AbstractFileStoreTable.java] 3 [paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java]--[paimon-core/src/main/java/org/apache/paimon/schema/SchemaValidation.java] 3 [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] 2 [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/MySqlSyncDatabaseActionFactory.java] [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] 3 [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] 3 [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] 2 [paimon-core/src/main/java/org/apache/paimon/schema/SchemaValidation.java]--[paimon-core/src/main/java/org/apache/paimon/table/ChangelogWithKeyFileStoreTable.java] 3 [paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreRead.java] [paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreRead.java] [paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreRead.java]--[paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/SnapshotReaderImpl.java] 3 [paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/hive/HiveCatalog.java] [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] [paimon-core/src/main/java/org/apache/paimon/catalog/Catalog.java] [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] 3 [paimon-core/src/main/java/org/apache/paimon/catalog/AbstractCatalog.java] [paimon-core/src/main/java/org/apache/paimon/catalog/AbstractCatalog.java] [paimon-core/src/main/java/org/apache/paimon/catalog/Catalog.java]--[paimon-core/src/main/java/org/apache/paimon/catalog/AbstractCatalog.java] 2 [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/UpdatedDataFieldsProcessFunction.java] [paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/MultiTableUpdatedDataFieldsProcessFunction.java] [paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/MultiTableUpdatedDataFieldsProcessFunction.java] [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] 3 [paimon-core/src/main/java/org/apache/paimon/table/system/AuditLogTable.java] [paimon-core/src/main/java/org/apache/paimon/table/system/AuditLogTable.java] [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] 3 [paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalog.java] [paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkCatalog.java] [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] 3 [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/sink/cdc/RichCdcMultiplexRecordEventParser.java] [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] 3 [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/kafka/canal/CanalRecordParser.java] [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] 3 [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/kafka/KafkaSyncDatabaseActionFactory.java] [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] 2 [paimon-core/src/main/java/org/apache/paimon/table/system/BucketsTable.java] [paimon-core/src/main/java/org/apache/paimon/table/system/BucketsTable.java] [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] 2 [paimon-core/src/main/java/org/apache/paimon/table/system/BucketsTable.java]--[paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java] 2 [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/cdc/CdcRecordStoreMultiWriteOperator.java] [paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreSinkWriteImpl.java] [paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreSinkWriteImpl.java] [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] 2 [paimon-core/src/main/java/org/apache/paimon/table/sink/TableWriteImpl.java] [paimon-core/src/main/java/org/apache/paimon/table/sink/TableWriteImpl.java] [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] 2 [paimon-core/src/main/java/org/apache/paimon/table/source/InnerStreamTableScanImpl.java] [paimon-core/src/main/java/org/apache/paimon/table/source/InnerStreamTableScanImpl.java] [paimon-core/src/main/java/org/apache/paimon/table/source/InnerStreamTableScanImpl.java]--[paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java] 2 [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/DropPartitionAction.java] [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] 2 [paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/AppendOnlyTableCompactionWorkerOperator.java] [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] [paimon-core/src/main/java/org/apache/paimon/append/AppendOnlyCompactionTask.java] [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] 2 [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/mapred/PaimonInputFormat.java] [paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/HiveSchema.java] [paimon-hive/paimon-hive-connector-common/src/main/java/org/apache/paimon/hive/HiveSchema.java] [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] 2 [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/CheckpointEvent.java] [paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/AlignedContinuousFileSplitEnumerator.java] [paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/align/AlignedContinuousFileSplitEnumerator.java] [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] 2
Download: SVG DOT (open online Graphviz editor)

Open 3D force graph (file dependencies)...
Open 3D force graph (file dependencies with commits)...
Dependencies between components in same commits (primary)
The number on the lines shows the number of shared commits.
G paimon-flink paimon-flink paimon-flink--paimon-flink 28 paimon-core paimon-core paimon-flink--paimon-core 14 paimon-common paimon-common paimon-flink--paimon-common 7 paimon-core--paimon-core 28 paimon-core--paimon-common 13 paimon-common--paimon-common 8 paimon-hive paimon-hive paimon-common--paimon-hive 1 paimon-hive--paimon-flink 2 paimon-hive--paimon-core 4 paimon-hive--paimon-hive 5 paimon-spark paimon-spark paimon-spark--paimon-flink 2 paimon-spark--paimon-core 3 paimon-spark--paimon-common 2 paimon-spark--paimon-hive 1 paimon-spark--paimon-spark 5 paimon-format paimon-format paimon-format--paimon-core 1 paimon-format--paimon-common 2 paimon-format--paimon-format 2 paimon-codegen paimon-codegen paimon-codegen--paimon-core 1 paimon-codegen--paimon-common 1 paimon-filesystems paimon-filesystems paimon-filesystems--paimon-common 1 paimon-filesystems--paimon-filesystems 1
Download: SVG DOT (open online Graphviz editor)

Open 3D force graph (file dependencies)...