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).
No file pairs changed together.
No temporal dependencies found.
No temporal dependencies found.
| Pairs | # same commits | # commits 1 | # commits 2 | latest commit |
|---|---|---|---|---|
| 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 |
2 | 31 (6%) | 24 (8%) | 2025-03-18 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/SQLParserSchemaChange.java flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImplV2.java |
2 | 7 (28%) | 15 (13%) | 2025-03-19 |
| 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 | 26 (7%) | 24 (8%) | 2025-03-18 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/SQLParserSchemaChange.java flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChange.java |
2 | 7 (28%) | 8 (25%) | 2025-03-19 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java |
2 | 26 (7%) | 31 (6%) | 2025-03-18 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImplV2.java flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChange.java |
2 | 15 (13%) | 8 (25%) | 2025-03-19 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumDataChange.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoDBJsonDebeziumSchemaSerializer.java |
1 | 4 (25%) | 5 (20%) | 2025-03-27 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumDataChange.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBDatabaseSync.java |
1 | 4 (25%) | 10 (10%) | 2025-03-27 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java |
1 | 20 (5%) | 51 (1%) | 2025-02-26 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java |
1 | 20 (5%) | 27 (3%) | 2025-02-11 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumDataChange.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBSchema.java |
1 | 4 (25%) | 5 (20%) | 2025-03-27 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/DorisTableUtil.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBSchema.java |
1 | 1 (100%) | 5 (20%) | 2025-03-27 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LoadConstants.java flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java |
1 | 8 (12%) | 24 (4%) | 2025-03-18 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/ChangeStreamConstant.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBType.java |
1 | 2 (50%) | 4 (25%) | 2025-02-10 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumSchemaChange.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoDBJsonDebeziumSchemaSerializer.java |
1 | 4 (25%) | 5 (20%) | 2025-03-27 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/ValueReader.java flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/ConfigurationOptions.java |
1 | 4 (25%) | 8 (12%) | 2025-03-13 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoParsingProcessFunction.java flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java |
1 | 3 (33%) | 20 (5%) | 2025-02-26 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DataModel.java flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java |
1 | 3 (33%) | 12 (8%) | 2025-03-12 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumChangeContext.java flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSchemaFactory.java |
1 | 6 (16%) | 5 (20%) | 2025-02-26 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java |
1 | 27 (3%) | 26 (3%) | 2025-03-13 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChange.java |
1 | 20 (5%) | 8 (12%) | 2025-02-26 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/DorisTableUtil.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumSchemaChange.java |
1 | 1 (100%) | 4 (25%) | 2025-03-27 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RecordStream.java flink-doris-connector/src/main/java/org/apache/doris/flink/exception/LabelAlreadyExistsException.java |
1 | 4 (25%) | 2 (50%) | 2025-03-18 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/DorisTableUtil.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java |
1 | 1 (100%) | 51 (1%) | 2025-03-27 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/converter/TableNameConverter.java flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImplV2.java |
1 | 1 (100%) | 15 (6%) | 2025-02-26 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoParsingProcessFunction.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/ParsingProcessFunction.java |
1 | 3 (33%) | 5 (20%) | 2025-02-26 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoParsingProcessFunction.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/converter/TableNameConverter.java |
1 | 3 (33%) | 1 (100%) | 2025-02-26 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LoadConstants.java flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java |
1 | 8 (12%) | 29 (3%) | 2025-03-18 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java |
1 | 12 (8%) | 26 (3%) | 2025-03-13 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBSchema.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBDatabaseSync.java |
1 | 5 (20%) | 10 (10%) | 2025-03-27 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumSchemaChange.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBType.java |
1 | 4 (25%) | 4 (25%) | 2025-02-10 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/JsonNodeExtractUtil.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/DorisTableUtil.java |
1 | 1 (100%) | 1 (100%) | 2025-03-27 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/ParsingProcessFunction.java flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumChangeContext.java |
1 | 5 (20%) | 6 (16%) | 2025-02-26 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RecordBuffer.java |
1 | 26 (3%) | 4 (25%) | 2025-03-18 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoParsingProcessFunction.java flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/SQLParserSchemaChange.java |
1 | 3 (33%) | 7 (14%) | 2025-02-26 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumSchemaChange.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumDataChange.java |
1 | 4 (25%) | 4 (25%) | 2025-03-27 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBSchema.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java |
1 | 5 (20%) | 51 (1%) | 2025-03-27 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/ValueReader.java flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java |
1 | 4 (25%) | 26 (3%) | 2025-03-13 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java |
1 | 20 (5%) | 12 (8%) | 2025-02-12 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RecordBuffer.java flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java |
1 | 4 (25%) | 24 (4%) | 2025-03-18 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChange.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java |
1 | 8 (12%) | 51 (1%) | 2025-02-26 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/DorisTableUtil.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoDBJsonDebeziumSchemaSerializer.java |
1 | 1 (100%) | 5 (20%) | 2025-03-27 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/JsonNodeExtractUtil.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumSchemaChange.java |
1 | 1 (100%) | 4 (25%) | 2025-03-27 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumSchemaChange.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBSchema.java |
1 | 4 (25%) | 5 (20%) | 2025-03-27 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/DorisTableUtil.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBDatabaseSync.java |
1 | 1 (100%) | 10 (10%) | 2025-03-27 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/JsonNodeExtractUtil.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java |
1 | 1 (100%) | 51 (1%) | 2025-03-27 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/ParsingProcessFunction.java flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/SQLParserSchemaChange.java |
1 | 5 (20%) | 7 (14%) | 2025-02-26 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/JsonNodeExtractUtil.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumDataChange.java |
1 | 1 (100%) | 4 (25%) | 2025-03-27 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/ParsingProcessFunction.java flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java |
1 | 5 (20%) | 20 (5%) | 2025-02-26 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RecordStream.java flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LoadConstants.java |
1 | 4 (25%) | 8 (12%) | 2025-03-18 |
| Pairs | # same commits | # commits 1 | # commits 2 | latest commit |
|---|---|---|---|---|
| flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/SQLParserSchemaChange.java flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChange.java |
2 | 7 (28%) | 8 (25%) | 2025-03-19 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImplV2.java flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChange.java |
2 | 15 (13%) | 8 (25%) | 2025-03-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/cfg/DorisExecutionOptions.java |
2 | 31 (6%) | 24 (8%) | 2025-03-18 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSchemaFactory.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java |
2 | 5 (40%) | 51 (3%) | 2025-02-26 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoParsingProcessFunction.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/ParsingProcessFunction.java |
2 | 3 (66%) | 5 (40%) | 2025-02-26 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBDatabaseSync.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java |
2 | 10 (20%) | 51 (3%) | 2025-03-27 |
| 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/DorisStreamLoad.java |
2 | 31 (6%) | 29 (6%) | 2025-03-18 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java |
2 | 26 (7%) | 31 (6%) | 2025-03-18 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoParsingProcessFunction.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java |
2 | 3 (66%) | 51 (3%) | 2025-02-26 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/ConfigurationOptions.java |
2 | 12 (16%) | 8 (25%) | 2025-03-13 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/ParsingProcessFunction.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java |
2 | 5 (40%) | 51 (3%) | 2025-02-26 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/ValueReader.java flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java |
2 | 4 (50%) | 27 (7%) | 2025-03-13 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DorisTableConfig.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java |
2 | 4 (50%) | 51 (3%) | 2024-12-06 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/SQLParserSchemaChange.java flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImplV2.java |
2 | 7 (28%) | 15 (13%) | 2025-03-19 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/sink/committer/DorisCommitter.java flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java |
2 | 14 (14%) | 31 (6%) | 2025-01-07 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumSchemaChange.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoDBJsonDebeziumSchemaSerializer.java |
2 | 4 (50%) | 5 (40%) | 2025-03-27 |
| 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 | 26 (7%) | 24 (8%) | 2025-03-18 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoParsingProcessFunction.java flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChange.java |
1 | 3 (33%) | 8 (12%) | 2025-02-26 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java |
1 | 27 (3%) | 12 (8%) | 2025-03-13 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java |
1 | 20 (5%) | 27 (3%) | 2025-02-11 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Tablet.java flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/QueryPlan.java |
1 | 4 (25%) | 4 (25%) | 2025-01-23 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/DorisTableUtil.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java |
1 | 1 (100%) | 51 (1%) | 2025-03-27 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LoadConstants.java flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java |
1 | 8 (12%) | 29 (3%) | 2025-03-18 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoParsingProcessFunction.java flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/SQLParserSchemaChange.java |
1 | 3 (33%) | 7 (14%) | 2025-02-26 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoDBJsonDebeziumSchemaSerializer.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBDatabaseSync.java |
1 | 5 (20%) | 10 (10%) | 2025-03-27 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RecordBuffer.java flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java |
1 | 4 (25%) | 24 (4%) | 2025-03-18 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java |
1 | 12 (8%) | 23 (4%) | 2024-12-06 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java |
1 | 27 (3%) | 26 (3%) | 2025-03-13 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/converter/TableNameConverter.java flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImplV2.java |
1 | 1 (100%) | 15 (6%) | 2025-02-26 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/DorisTableUtil.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoDBJsonDebeziumSchemaSerializer.java |
1 | 1 (100%) | 5 (20%) | 2025-03-27 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisValueReader.java |
1 | 20 (5%) | 8 (12%) | 2025-02-12 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/QueryPlan.java flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Field.java |
1 | 4 (25%) | 4 (25%) | 2025-01-23 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java |
1 | 26 (3%) | 29 (3%) | 2025-03-18 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RecordStream.java |
1 | 26 (3%) | 4 (25%) | 2025-03-18 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/sink/committer/DorisCommitter.java flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/ConfigurationOptions.java |
1 | 14 (7%) | 8 (12%) | 2024-12-06 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumChangeContext.java flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSchemaFactory.java |
1 | 6 (16%) | 5 (20%) | 2025-02-26 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoParsingProcessFunction.java flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImplV2.java |
1 | 3 (33%) | 15 (6%) | 2025-02-26 |
| 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/DorisWriter.java |
1 | 23 (4%) | 31 (3%) | 2024-12-06 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RecordStream.java flink-doris-connector/src/main/java/org/apache/doris/flink/exception/LabelAlreadyExistsException.java |
1 | 4 (25%) | 2 (50%) | 2025-03-18 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/CdcSchemaChange.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumSchemaChange.java |
1 | 2 (50%) | 4 (25%) | 2025-01-10 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumDataChange.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBSchema.java |
1 | 4 (25%) | 5 (20%) | 2025-03-27 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/TableSchema.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DorisTableConfig.java |
1 | 6 (16%) | 4 (25%) | 2024-12-02 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/exception/LabelAlreadyExistsException.java flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java |
1 | 2 (50%) | 24 (4%) | 2025-03-18 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Schema.java flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/QueryPlan.java |
1 | 4 (25%) | 4 (25%) | 2025-01-23 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Tablet.java flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Field.java |
1 | 4 (25%) | 4 (25%) | 2025-01-23 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/ChangeStreamConstant.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBType.java |
1 | 2 (50%) | 4 (25%) | 2025-02-10 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LoadConstants.java flink-doris-connector/src/main/java/org/apache/doris/flink/exception/LabelAlreadyExistsException.java |
1 | 8 (12%) | 2 (50%) | 2025-03-18 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumChangeContext.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java |
1 | 6 (16%) | 51 (1%) | 2025-02-26 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/JsonNodeExtractUtil.java flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBSchema.java |
1 | 1 (100%) | 5 (20%) | 2025-03-27 |
| flink-doris-connector/src/main/java/org/apache/doris/flink/source/DorisSource.java flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisFlightValueReader.java |
1 | 10 (10%) | 3 (33%) | 2024-12-26 |
