apache / doris-flink-connector
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
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/JsonDebeziumSchemaSerializer.java		 3 6 (50%) 9 (33%) 2023-08-07
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java		 3 4 (75%) 6 (50%) 2023-08-03
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/SourceSchema.java
flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java		 3 4 (75%) 5 (60%) 2023-08-03
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/SourceSchema.java		 2 2 (100%) 4 (50%) 2023-07-21
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java
flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java		 2 2 (100%) 5 (40%) 2023-07-21
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java		 2 9 (22%) 7 (28%) 2023-08-07
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java		 2 12 (16%) 7 (28%) 2023-08-07
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java		 2 4 (50%) 4 (50%) 2023-07-21
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/JsonDebeziumSchemaSerializer.java		 2 4 (50%) 9 (22%) 2023-08-03
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java
flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java		 2 12 (16%) 9 (22%) 2023-08-07
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java
flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java		 2 7 (28%) 9 (22%) 2023-08-07
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java
flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java		 2 9 (22%) 9 (22%) 2023-08-07
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java		 2 4 (50%) 6 (33%) 2023-07-21
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java		 2 9 (22%) 12 (16%) 2023-08-07
flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/FieldSchema.java
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java		 1 2 (50%) 6 (16%) 2023-08-03
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataJdbcLookupFunction.java
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataAsyncLookupFunction.java		 1 2 (50%) 3 (33%) 2023-07-17
flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/DorisJdbcLookupReader.java
flink-doris-connector/src/main/java/org/apache/doris/flink/connection/SimpleJdbcConnectionProvider.java		 1 2 (50%) 2 (50%) 2023-07-17
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java		 1 6 (16%) 12 (8%) 2023-08-07
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/BackendUtil.java
flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java		 1 1 (100%) 9 (11%) 2023-08-07
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LabelGenerator.java
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchSink.java		 1 3 (33%) 1 (100%) 2023-08-07
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/BackendUtil.java
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java		 1 1 (100%) 12 (8%) 2023-08-07
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LabelGenerator.java
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java		 1 3 (33%) 7 (14%) 2023-08-07
flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java		 1 5 (20%) 4 (25%) 2023-07-19
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlSchema.java
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/SourceSchema.java		 1 1 (100%) 4 (25%) 2023-07-19
flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/ExecutionPool.java
flink-doris-connector/src/main/java/org/apache/doris/flink/connection/SimpleJdbcConnectionProvider.java		 1 2 (50%) 2 (50%) 2023-07-17
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDateConverter.java
flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java		 1 1 (100%) 5 (20%) 2023-07-19
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataAsyncLookupFunction.java
flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Worker.java		 1 3 (33%) 2 (50%) 2023-07-17
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchWriter.java
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchSink.java		 1 1 (100%) 1 (100%) 2023-08-07
flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisBatchLoadException.java
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java		 1 1 (100%) 12 (8%) 2023-08-07
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchSink.java
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java		 1 1 (100%) 9 (11%) 2023-08-07
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java		 1 2 (50%) 6 (16%) 2023-07-19
flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/DorisJsonDebeziumDeserializationSchema.java
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/JsonDebeziumSchemaSerializer.java		 1 1 (100%) 9 (11%) 2023-07-21
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java
flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java		 1 9 (11%) 9 (11%) 2023-08-07
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchRecordBuffer.java
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java		 1 1 (100%) 7 (14%) 2023-08-07
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataJdbcLookupFunction.java
flink-doris-connector/src/main/java/org/apache/doris/flink/connection/SimpleJdbcConnectionProvider.java		 1 2 (50%) 2 (50%) 2023-07-17
flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisBatchLoadException.java
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java		 1 1 (100%) 9 (11%) 2023-08-07
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/SourceSchema.java
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java		 1 4 (25%) 6 (16%) 2023-07-19
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java		 1 9 (11%) 12 (8%) 2023-08-07
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchRecordBuffer.java
flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java		 1 1 (100%) 9 (11%) 2023-08-07
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/BackendUtil.java
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java		 1 1 (100%) 9 (11%) 2023-08-07
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/JsonDebeziumSchemaSerializer.java		 1 9 (11%) 9 (11%) 2023-08-07
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/BackendUtil.java
flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisBatchLoadException.java		 1 1 (100%) 1 (100%) 2023-08-07
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataAsyncLookupFunction.java
flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/DorisLookupReader.java		 1 3 (33%) 2 (50%) 2023-07-17
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchSink.java
flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java		 1 1 (100%) 9 (11%) 2023-08-07
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlSchema.java
flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java		 1 1 (100%) 5 (20%) 2023-07-19
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LabelGenerator.java
flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisBatchLoadException.java		 1 3 (33%) 1 (100%) 2023-08-07
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlSchema.java
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java		 1 1 (100%) 6 (16%) 2023-07-19
flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Worker.java
flink-doris-connector/src/main/java/org/apache/doris/flink/connection/SimpleJdbcConnectionProvider.java		 1 2 (50%) 2 (50%) 2023-07-17
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/SchemaChangeHelper.java		 1 4 (25%) 1 (100%) 2023-08-03
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LabelGenerator.java
flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java		 1 3 (33%) 1 (100%) 2023-08-07
Dependencies between files in same commits
The number on the lines shows the number of shared commits.
G [flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/JsonDebeziumSchemaSerializer.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/JsonDebeziumSchemaSerializer.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/JsonDebeziumSchemaSerializer.java] 3 [flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java] 3 [flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/JsonDebeziumSchemaSerializer.java] 2 [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/SchemaChangeHelper.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/SchemaChangeHelper.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/SchemaChangeHelper.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/SourceSchema.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/SourceSchema.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/SourceSchema.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/SourceSchema.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java] 3 [flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/SourceSchema.java] 2 [flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java] 2 [flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/JsonDebeziumSchemaSerializer.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java] 2 [flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java] 2 [flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java] 2 [flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java] 2 [flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java] 2 [flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java] 2 [flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java] 2 [flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java] 2 [flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/FieldSchema.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/FieldSchema.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/FieldSchema.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataJdbcLookupFunction.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataJdbcLookupFunction.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataAsyncLookupFunction.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataAsyncLookupFunction.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataJdbcLookupFunction.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataAsyncLookupFunction.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/connection/SimpleJdbcConnectionProvider.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/connection/SimpleJdbcConnectionProvider.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataJdbcLookupFunction.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/connection/SimpleJdbcConnectionProvider.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Worker.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Worker.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataAsyncLookupFunction.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Worker.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/DorisLookupReader.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/DorisLookupReader.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataAsyncLookupFunction.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/DorisLookupReader.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/DorisJdbcLookupReader.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/DorisJdbcLookupReader.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/DorisJdbcLookupReader.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/connection/SimpleJdbcConnectionProvider.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/BackendUtil.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/BackendUtil.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/BackendUtil.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/BackendUtil.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/BackendUtil.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisBatchLoadException.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisBatchLoadException.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/BackendUtil.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisBatchLoadException.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LabelGenerator.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LabelGenerator.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LabelGenerator.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchSink.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchSink.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LabelGenerator.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchSink.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LabelGenerator.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisBatchLoadException.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LabelGenerator.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchSink.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchSink.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlSchema.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlSchema.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlSchema.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlSchema.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/SourceSchema.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlSchema.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/ExecutionPool.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/ExecutionPool.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/ExecutionPool.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/connection/SimpleJdbcConnectionProvider.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDateConverter.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDateConverter.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDateConverter.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Worker.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/connection/SimpleJdbcConnectionProvider.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchWriter.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchWriter.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchWriter.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchSink.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisBatchLoadException.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisBatchLoadException.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/DorisJsonDebeziumDeserializationSchema.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/DorisJsonDebeziumDeserializationSchema.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/DorisJsonDebeziumDeserializationSchema.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/JsonDebeziumSchemaSerializer.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchRecordBuffer.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchRecordBuffer.java] [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchRecordBuffer.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java] 1 [flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchRecordBuffer.java]--[flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java] 1
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 flink-doris-connector flink-doris-connector flink-doris-connector--flink-doris-connector 8
Download: SVG DOT (open online Graphviz editor)

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