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 |
---|---|---|---|---|
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceFunction.java |
1 | 3 (33%) | 3 (33%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplit.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceInitAssignEvent.java |
1 | 2 (50%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQPartitionSplitSerializer.java src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceFetcherManager.java |
1 | 2 (50%) | 2 (50%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceDetectEvent.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceCheckEvent.java |
1 | 1 (100%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplit.java src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java |
1 | 2 (50%) | 3 (33%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplitState.java src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplit.java |
1 | 2 (50%) | 2 (50%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategy.java |
1 | 3 (33%) | 2 (50%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQPartitionSplitSerializer.java src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializer.java |
1 | 2 (50%) | 3 (33%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/ConsistentHashAllocateStrategy.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceReportOffsetEvent.java |
1 | 2 (50%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AverageAllocateStrategy.java |
1 | 2 (50%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategyFactory.java |
1 | 2 (50%) | 2 (50%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/ConsistentHashAllocateStrategy.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceDetectEvent.java |
1 | 2 (50%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/common/lock/SpinLock.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceInitAssignEvent.java |
1 | 1 (100%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/metrics/RocketMQSourceReaderMetrics.java src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/ConsistentHashAllocateStrategy.java |
1 | 2 (50%) | 2 (50%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplitState.java src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceFunction.java |
1 | 2 (50%) | 3 (33%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/BroadcastAllocateStrategy.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceInitAssignEvent.java |
1 | 2 (50%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/BroadcastAllocateStrategy.java src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializer.java |
1 | 2 (50%) | 3 (33%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSource.java |
1 | 2 (50%) | 2 (50%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializer.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceDetectEvent.java |
1 | 3 (33%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/BroadcastAllocateStrategy.java src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java |
1 | 2 (50%) | 3 (33%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQPartitionSplitSerializer.java src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategyFactory.java |
1 | 2 (50%) | 2 (50%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializer.java src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java |
1 | 3 (33%) | 3 (33%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceFetcherManager.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceCheckEvent.java |
1 | 2 (50%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceReportOffsetEvent.java |
1 | 2 (50%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceInitAssignEvent.java |
1 | 2 (50%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplit.java src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AverageAllocateStrategy.java |
1 | 2 (50%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategyFactory.java src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializer.java |
1 | 2 (50%) | 3 (33%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/BroadcastAllocateStrategy.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceCheckEvent.java |
1 | 2 (50%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplit.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceReportOffsetEvent.java |
1 | 2 (50%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/ConsistentHashAllocateStrategy.java src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategy.java |
1 | 2 (50%) | 2 (50%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQPartitionSplitSerializer.java src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java |
1 | 2 (50%) | 3 (33%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplit.java src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/ConsistentHashAllocateStrategy.java |
1 | 2 (50%) | 2 (50%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceFetcherManager.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceReportOffsetEvent.java |
1 | 2 (50%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/BroadcastAllocateStrategy.java src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumerator.java |
1 | 2 (50%) | 3 (33%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategy.java |
1 | 2 (50%) | 2 (50%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumerator.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceCheckEvent.java |
1 | 3 (33%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplitState.java src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceFetcherManager.java |
1 | 2 (50%) | 2 (50%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/ConsistentHashAllocateStrategy.java src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java |
1 | 2 (50%) | 3 (33%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java |
1 | 3 (33%) | 2 (50%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategyFactory.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceCheckEvent.java |
1 | 2 (50%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializer.java src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceFunction.java |
1 | 3 (33%) | 3 (33%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceReportOffsetEvent.java |
1 | 3 (33%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumerator.java src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java |
1 | 3 (33%) | 3 (33%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializer.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceInitAssignEvent.java |
1 | 3 (33%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/common/lock/SpinLock.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceReportOffsetEvent.java |
1 | 1 (100%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializer.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceCheckEvent.java |
1 | 3 (33%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceFetcherManager.java src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java |
1 | 2 (50%) | 3 (33%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategy.java src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumerator.java |
1 | 2 (50%) | 3 (33%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplitState.java src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategy.java |
1 | 2 (50%) | 2 (50%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AverageAllocateStrategy.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceReportOffsetEvent.java |
1 | 1 (100%) | 1 (100%) | 2025-03-06 |
Pairs | # same commits | # commits 1 | # commits 2 | latest commit |
---|---|---|---|---|
src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceInitAssignEvent.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceDetectEvent.java |
1 | 1 (100%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategyFactory.java src/main/java/org/apache/flink/connector/rocketmq/common/lock/SpinLock.java |
1 | 2 (50%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/BroadcastAllocateStrategy.java src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategy.java |
1 | 2 (50%) | 2 (50%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceDetectEvent.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceCheckEvent.java |
1 | 1 (100%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceReportOffsetEvent.java |
1 | 3 (33%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceFetcherManager.java |
1 | 3 (33%) | 2 (50%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/BroadcastAllocateStrategy.java src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java |
1 | 2 (50%) | 3 (33%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/BroadcastAllocateStrategy.java src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AverageAllocateStrategy.java |
1 | 2 (50%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AverageAllocateStrategy.java |
1 | 2 (50%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AverageAllocateStrategy.java src/main/java/org/apache/flink/connector/rocketmq/common/lock/SpinLock.java |
1 | 1 (100%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplitState.java src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java |
1 | 2 (50%) | 2 (50%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceReportOffsetEvent.java |
1 | 3 (33%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumerator.java src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceFunction.java |
1 | 3 (33%) | 3 (33%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategy.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceInitAssignEvent.java |
1 | 2 (50%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQPartitionSplitSerializer.java src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializer.java |
1 | 2 (50%) | 3 (33%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceDetectEvent.java |
1 | 3 (33%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceFunction.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceDetectEvent.java |
1 | 3 (33%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializer.java src/main/java/org/apache/flink/connector/rocketmq/common/lock/SpinLock.java |
1 | 3 (33%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplitState.java src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplit.java |
1 | 2 (50%) | 2 (50%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceFetcherManager.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceReportOffsetEvent.java |
1 | 2 (50%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceFunction.java |
1 | 2 (50%) | 3 (33%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceFunction.java |
1 | 3 (33%) | 3 (33%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/RocketMQSource.java src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java |
1 | 2 (50%) | 3 (33%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceFetcherManager.java src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceFunction.java |
1 | 2 (50%) | 3 (33%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializer.java |
1 | 3 (33%) | 3 (33%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceCheckEvent.java |
1 | 3 (33%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQPartitionSplitSerializer.java src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategy.java |
1 | 2 (50%) | 2 (50%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceReportOffsetEvent.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceDetectEvent.java |
1 | 1 (100%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplitState.java src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSplitReader.java |
1 | 2 (50%) | 3 (33%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceFunction.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceInitAssignEvent.java |
1 | 3 (33%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializer.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceDetectEvent.java |
1 | 3 (33%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/metrics/RocketMQSourceReaderMetrics.java src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AverageAllocateStrategy.java |
1 | 2 (50%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/metrics/RocketMQSourceReaderMetrics.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceCheckEvent.java |
1 | 2 (50%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplit.java src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AverageAllocateStrategy.java |
1 | 2 (50%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/BroadcastAllocateStrategy.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceDetectEvent.java |
1 | 2 (50%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQPartitionSplitSerializer.java src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumerator.java |
1 | 2 (50%) | 3 (33%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQPartitionSplitSerializer.java src/main/java/org/apache/flink/connector/rocketmq/source/metrics/RocketMQSourceReaderMetrics.java |
1 | 2 (50%) | 2 (50%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/reader/RocketMQSourceReader.java src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/ConsistentHashAllocateStrategy.java |
1 | 2 (50%) | 2 (50%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplitState.java src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java |
1 | 2 (50%) | 3 (33%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplit.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceCheckEvent.java |
1 | 2 (50%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQPartitionSplitSerializer.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceCheckEvent.java |
1 | 2 (50%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/common/lock/SpinLock.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceCheckEvent.java |
1 | 1 (100%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumerator.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceCheckEvent.java |
1 | 3 (33%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/AllocateStrategy.java src/main/java/org/apache/flink/connector/rocketmq/common/lock/SpinLock.java |
1 | 2 (50%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumerator.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceDetectEvent.java |
1 | 3 (33%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/split/RocketMQSourceSplit.java src/main/java/org/apache/flink/connector/rocketmq/source/metrics/RocketMQSourceReaderMetrics.java |
1 | 2 (50%) | 2 (50%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java src/main/java/org/apache/flink/connector/rocketmq/legacy/RocketMQSourceFunction.java |
1 | 3 (33%) | 3 (33%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/allocate/BroadcastAllocateStrategy.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceInitAssignEvent.java |
1 | 2 (50%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializer.java src/main/java/org/apache/flink/connector/rocketmq/common/event/SourceCheckEvent.java |
1 | 3 (33%) | 1 (100%) | 2025-03-06 |
src/main/java/org/apache/flink/connector/rocketmq/source/enumerator/RocketMQSourceEnumStateSerializer.java src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java |
1 | 3 (33%) | 3 (33%) | 2025-03-06 |