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).
| Pairs | # same commits | # commits 1 | # commits 2 | latest commit |
|---|---|---|---|---|
| flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/TimestampOffsetsInitializer.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/SpecifiedOffsetsInitializer.java |
1 | 4 (25%) | 5 (20%) | 2023-07-11 |
| Pairs | # same commits | # commits 1 | # commits 2 | latest commit |
|---|---|---|---|---|
| flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/TimestampOffsetsInitializer.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/SpecifiedOffsetsInitializer.java |
1 | 4 (25%) | 5 (20%) | 2023-07-11 |
| Pairs | # same commits | # commits 1 | # commits 2 | latest commit |
|---|---|---|---|---|
| flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TwoPhaseCommittingStatefulSink.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java |
1 | 1 (100%) | 26 (3%) | 2023-03-12 |
| flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumStateSerializer.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/AssignmentStatus.java |
1 | 5 (20%) | 1 (100%) | 2023-05-06 |
| flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumState.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/AssignmentStatus.java |
1 | 5 (20%) | 1 (100%) | 2023-05-06 |
| flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java |
1 | 26 (3%) | 26 (3%) | 2023-03-12 |
| flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/AssignmentStatus.java |
1 | 17 (5%) | 1 (100%) | 2023-05-06 |
| flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/TimestampOffsetsInitializer.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/initializer/SpecifiedOffsetsInitializer.java |
1 | 4 (25%) | 5 (20%) | 2023-07-11 |
| flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumState.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSource.java |
1 | 5 (20%) | 17 (5%) | 2023-05-06 |
| flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactory.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSink.java |
1 | 13 (7%) | 5 (20%) | 2023-03-12 |
| flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/FlinkKafkaInternalProducer.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java |
1 | 6 (16%) | 16 (6%) | 2023-03-23 |
| flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactory.java flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertWriter.java |
1 | 13 (7%) | 8 (12%) | 2023-03-12 |
| flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumStateSerializer.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumState.java |
1 | 5 (20%) | 5 (20%) | 2023-05-06 |
| flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertWriter.java flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertSink.java |
1 | 8 (12%) | 6 (16%) | 2023-03-12 |
| flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TwoPhaseCommittingStatefulSink.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSink.java |
1 | 1 (100%) | 5 (20%) | 2023-03-12 |
| flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptions.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceOptions.java |
1 | 5 (20%) | 8 (12%) | 2023-05-06 |
| flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/TopicPartitionAndAssignmentStatus.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSource.java |
1 | 1 (100%) | 17 (5%) | 2023-05-06 |
| flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/TopicPartitionAndAssignmentStatus.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/AssignmentStatus.java |
1 | 1 (100%) | 1 (100%) | 2023-05-06 |
| flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TwoPhaseCommittingStatefulSink.java |
1 | 26 (3%) | 1 (100%) | 2023-03-12 |
| flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptionsUtil.java flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactory.java |
1 | 8 (12%) | 13 (7%) | 2023-04-05 |
| flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/FlinkKafkaInternalProducer.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java |
1 | 6 (16%) | 11 (9%) | 2023-03-23 |
| flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertSink.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java |
1 | 6 (16%) | 26 (3%) | 2023-03-12 |
| flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/AssignmentStatus.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSource.java |
1 | 1 (100%) | 17 (5%) | 2023-05-06 |
| flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertSink.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSink.java |
1 | 6 (16%) | 5 (20%) | 2023-03-12 |
| flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumState.java |
1 | 17 (5%) | 5 (20%) | 2023-05-06 |
| flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactory.java flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java |
1 | 13 (7%) | 26 (3%) | 2023-03-12 |
| flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceOptions.java |
1 | 23 (4%) | 8 (12%) | 2023-05-06 |
| flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertSink.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TwoPhaseCommittingStatefulSink.java |
1 | 6 (16%) | 1 (100%) | 2023-03-12 |
| flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/HeaderProvider.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchemaBuilder.java |
1 | 1 (100%) | 7 (14%) | 2023-03-27 |
| flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactory.java flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertSink.java |
1 | 13 (7%) | 6 (16%) | 2023-03-12 |
| flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactory.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java |
1 | 13 (7%) | 26 (3%) | 2023-03-12 |
| flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumStateSerializer.java |
1 | 17 (5%) | 5 (20%) | 2023-05-06 |
| flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertWriter.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TwoPhaseCommittingStatefulSink.java |
1 | 8 (12%) | 1 (100%) | 2023-03-12 |
| flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSink.java |
1 | 26 (3%) | 5 (20%) | 2023-03-12 |
| flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertSink.java flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java |
1 | 6 (16%) | 26 (3%) | 2023-03-12 |
| flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/TopicPartitionAndAssignmentStatus.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumState.java |
1 | 1 (100%) | 5 (20%) | 2023-05-06 |
| flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumStateSerializer.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSource.java |
1 | 5 (20%) | 17 (5%) | 2023-05-06 |
| flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSource.java |
1 | 17 (5%) | 17 (5%) | 2023-05-06 |
| flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java |
1 | 16 (6%) | 11 (9%) | 2023-03-23 |
| flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertWriter.java flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java |
1 | 8 (12%) | 26 (3%) | 2023-03-12 |
| flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertWriter.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java |
1 | 8 (12%) | 26 (3%) | 2023-03-12 |
| flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/ReducingUpsertWriter.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSink.java |
1 | 8 (12%) | 5 (20%) | 2023-03-12 |
| flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptions.java |
1 | 23 (4%) | 5 (20%) | 2023-05-06 |
| flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaDynamicTableFactory.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TwoPhaseCommittingStatefulSink.java |
1 | 13 (7%) | 1 (100%) | 2023-03-12 |
| flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/TopicPartitionAndAssignmentStatus.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumerator.java |
1 | 1 (100%) | 17 (5%) | 2023-05-06 |
| flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java |
1 | 11 (9%) | 26 (3%) | 2023-03-23 |
| flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/TopicPartitionAndAssignmentStatus.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/KafkaSourceEnumStateSerializer.java |
1 | 1 (100%) | 5 (20%) | 2023-05-06 |
| flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSink.java |
1 | 26 (3%) | 5 (20%) | 2023-03-12 |
