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 |
|---|---|---|---|---|
| core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AggregateSessionWindowFire.java core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AccumulatorSessionWindowFire.java |
1 | 9 (11%) | 9 (11%) | 2023-07-19 |
| core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AggregateSessionWindowFire.java |
1 | 10 (10%) | 9 (11%) | 2023-07-19 |
| core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AccumulatorSessionWindowFire.java |
1 | 10 (10%) | 9 (11%) | 2023-07-19 |
| Pairs | # same commits | # commits 1 | # commits 2 | latest commit |
|---|---|---|---|---|
| core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java |
3 | 52 (5%) | 21 (14%) | 2023-06-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStream.java |
3 | 29 (10%) | 13 (23%) | 2023-06-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java |
3 | 52 (5%) | 29 (10%) | 2023-06-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java |
3 | 21 (14%) | 29 (10%) | 2023-06-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java core/src/main/java/org/apache/rocketmq/streams/core/running/MessageQueueListenerWrapper.java |
2 | 48 (4%) | 18 (11%) | 2023-06-20 |
| core/src/main/java/org/apache/rocketmq/streams/core/metadata/StreamConfig.java core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java |
2 | 17 (11%) | 48 (4%) | 2023-06-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java core/src/main/java/org/apache/rocketmq/streams/core/metadata/StreamConfig.java |
2 | 51 (3%) | 17 (11%) | 2023-06-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java |
2 | 51 (3%) | 48 (4%) | 2023-06-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java |
1 | 48 (2%) | 52 (1%) | 2023-06-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java |
1 | 48 (2%) | 21 (4%) | 2023-06-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ValueChangeSupplier.java |
1 | 29 (3%) | 12 (8%) | 2023-06-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ValueChangeSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/MultiValueChangeSupplier.java |
1 | 12 (8%) | 6 (16%) | 2023-06-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStream.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/MultiValueChangeSupplier.java |
1 | 13 (7%) | 6 (16%) | 2023-06-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/MultiValueChangeSupplier.java |
1 | 29 (3%) | 6 (16%) | 2023-06-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AggregateSessionWindowFire.java |
1 | 10 (10%) | 9 (11%) | 2023-07-19 |
| core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java |
1 | 51 (1%) | 29 (3%) | 2023-06-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/metadata/StreamConfig.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java |
1 | 17 (5%) | 52 (1%) | 2023-06-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/metadata/StreamConfig.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java |
1 | 17 (5%) | 29 (3%) | 2023-06-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java |
1 | 52 (1%) | 10 (10%) | 2023-05-22 |
| core/src/main/java/org/apache/rocketmq/streams/core/metadata/StreamConfig.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java |
1 | 17 (5%) | 21 (4%) | 2023-06-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java |
1 | 51 (1%) | 21 (4%) | 2023-06-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AccumulatorSessionWindowFire.java |
1 | 10 (10%) | 9 (11%) | 2023-07-19 |
| core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java |
1 | 21 (4%) | 10 (10%) | 2023-05-22 |
| core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStream.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ValueChangeSupplier.java |
1 | 13 (7%) | 12 (8%) | 2023-06-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AggregateSessionWindowFire.java core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AccumulatorSessionWindowFire.java |
1 | 9 (11%) | 9 (11%) | 2023-07-19 |
| core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java |
1 | 29 (3%) | 10 (10%) | 2023-05-22 |
| core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java |
1 | 51 (1%) | 52 (1%) | 2023-06-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java |
1 | 48 (2%) | 29 (3%) | 2023-06-02 |
| Pairs | # same commits | # commits 1 | # commits 2 | latest commit |
|---|---|---|---|---|
| core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStream.java |
5 | 32 (15%) | 20 (25%) | 2023-03-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ValueChangeSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/MultiValueChangeSupplier.java |
4 | 12 (33%) | 6 (66%) | 2023-06-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java |
3 | 52 (5%) | 29 (10%) | 2023-06-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStream.java |
3 | 29 (10%) | 13 (23%) | 2023-06-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/metadata/StreamConfig.java core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java |
3 | 17 (17%) | 48 (6%) | 2023-06-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java |
3 | 52 (5%) | 21 (14%) | 2023-06-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java |
3 | 21 (14%) | 29 (10%) | 2023-06-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java |
3 | 51 (5%) | 48 (6%) | 2023-06-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java core/src/main/java/org/apache/rocketmq/streams/core/metadata/StreamConfig.java |
3 | 51 (5%) | 17 (17%) | 2023-06-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator/AvgAccumulator.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java |
2 | 3 (66%) | 32 (6%) | 2023-02-09 |
| core/src/main/java/org/apache/rocketmq/streams/core/util/RocketMQUtil.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/SinkSupplier.java |
2 | 16 (12%) | 19 (10%) | 2023-02-14 |
| core/src/main/java/org/apache/rocketmq/streams/core/rstream/RStreamImpl.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/RStream.java |
2 | 17 (11%) | 14 (14%) | 2023-02-16 |
| core/src/main/java/org/apache/rocketmq/streams/core/util/RocketMQUtil.java core/src/main/java/org/apache/rocketmq/streams/core/util/OperatorNameMaker.java |
2 | 16 (12%) | 28 (7%) | 2023-02-14 |
| core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java core/src/main/java/org/apache/rocketmq/streams/core/running/MessageQueueListenerWrapper.java |
2 | 48 (4%) | 18 (11%) | 2023-06-20 |
| core/src/main/java/org/apache/rocketmq/streams/core/util/OperatorNameMaker.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/SinkSupplier.java |
2 | 28 (7%) | 19 (10%) | 2023-02-14 |
| core/src/main/java/org/apache/rocketmq/streams/core/util/OperatorNameMaker.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStream.java |
2 | 28 (7%) | 20 (10%) | 2023-02-09 |
| core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java |
2 | 32 (6%) | 29 (6%) | 2023-03-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AbstractWindowFire.java core/src/main/java/org/apache/rocketmq/streams/core/metadata/StreamConfig.java |
2 | 5 (40%) | 17 (11%) | 2023-02-14 |
| core/src/main/java/org/apache/rocketmq/streams/core/util/OperatorNameMaker.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java |
2 | 28 (7%) | 32 (6%) | 2023-02-09 |
| core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator/AvgAccumulator.java core/src/main/java/org/apache/rocketmq/streams/core/util/OperatorNameMaker.java |
2 | 3 (66%) | 28 (7%) | 2023-02-09 |
| core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStream.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java |
2 | 20 (10%) | 29 (6%) | 2023-03-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AbstractWindowFire.java core/src/main/java/org/apache/rocketmq/streams/core/running/AbstractWindowProcessor.java |
2 | 5 (40%) | 25 (8%) | 2023-02-14 |
| core/src/main/java/org/apache/rocketmq/streams/core/running/AbstractWindowProcessor.java core/src/main/java/org/apache/rocketmq/streams/core/metadata/StreamConfig.java |
2 | 25 (8%) | 17 (11%) | 2023-02-14 |
| core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator/AvgAccumulator.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStream.java |
2 | 3 (66%) | 20 (10%) | 2023-02-09 |
| core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AbstractWindowFire.java core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java |
1 | 5 (20%) | 48 (2%) | 2023-02-14 |
| core/src/main/java/org/apache/rocketmq/streams/core/util/OperatorNameMaker.java core/src/main/java/org/apache/rocketmq/streams/core/running/RocketMQClient.java |
1 | 28 (3%) | 8 (12%) | 2023-02-14 |
| core/src/main/java/org/apache/rocketmq/streams/core/rstream/StreamBuilder.java core/src/main/java/org/apache/rocketmq/streams/core/state/AbstractStore.java |
1 | 12 (8%) | 17 (5%) | 2023-02-14 |
| core/src/main/java/org/apache/rocketmq/streams/core/util/OperatorNameMaker.java core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java |
1 | 28 (3%) | 51 (1%) | 2023-02-14 |
| core/src/main/java/org/apache/rocketmq/streams/core/RocketMQStream.java core/src/main/java/org/apache/rocketmq/streams/core/metadata/StreamConfig.java |
1 | 20 (5%) | 17 (5%) | 2023-02-14 |
| core/src/main/java/org/apache/rocketmq/streams/core/rstream/Pipeline.java core/src/main/java/org/apache/rocketmq/streams/core/state/AbstractStore.java |
1 | 11 (9%) | 17 (5%) | 2023-02-14 |
| core/src/main/java/org/apache/rocketmq/streams/core/running/RocketMQClient.java core/src/main/java/org/apache/rocketmq/streams/core/metadata/StreamConfig.java |
1 | 8 (12%) | 17 (5%) | 2023-02-14 |
| core/src/main/java/org/apache/rocketmq/streams/core/running/RocketMQClient.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/Pipeline.java |
1 | 8 (12%) | 11 (9%) | 2023-02-14 |
| core/src/main/java/org/apache/rocketmq/streams/core/util/RocketMQUtil.java core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual/ProcessorNode.java |
1 | 16 (6%) | 7 (14%) | 2023-02-14 |
| core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual/ProcessorNode.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/SinkSupplier.java |
1 | 7 (14%) | 19 (5%) | 2023-02-14 |
| core/src/main/java/org/apache/rocketmq/streams/core/util/RocketMQUtil.java core/src/main/java/org/apache/rocketmq/streams/core/running/RocketMQClient.java |
1 | 16 (6%) | 8 (12%) | 2023-02-14 |
| core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/SinkSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/RocketMQStream.java |
1 | 19 (5%) | 20 (5%) | 2023-02-14 |
| core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java |
1 | 51 (1%) | 29 (3%) | 2023-06-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AccumulatorSessionWindowFire.java |
1 | 10 (10%) | 9 (11%) | 2023-07-19 |
| core/src/main/java/org/apache/rocketmq/streams/core/running/AbstractWindowProcessor.java core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java |
1 | 25 (4%) | 10 (10%) | 2023-02-14 |
| core/src/main/java/org/apache/rocketmq/streams/core/rstream/StreamBuilder.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/Pipeline.java |
1 | 12 (8%) | 11 (9%) | 2023-02-14 |
| core/src/main/java/org/apache/rocketmq/streams/core/state/AbstractStore.java core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java |
1 | 17 (5%) | 10 (10%) | 2023-02-14 |
| core/src/main/java/org/apache/rocketmq/streams/core/running/AbstractWindowProcessor.java core/src/main/java/org/apache/rocketmq/streams/core/state/AbstractStore.java |
1 | 25 (4%) | 17 (5%) | 2023-02-14 |
| core/src/main/java/org/apache/rocketmq/streams/core/rstream/Pipeline.java core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java |
1 | 11 (9%) | 51 (1%) | 2023-02-14 |
| core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AbstractWindowFire.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/Pipeline.java |
1 | 5 (20%) | 11 (9%) | 2023-02-14 |
| core/src/main/java/org/apache/rocketmq/streams/core/window/fire/JoinWindowFire.java core/src/main/java/org/apache/rocketmq/streams/core/running/AbstractWindowProcessor.java |
1 | 11 (9%) | 25 (4%) | 2023-02-14 |
| core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ValueChangeSupplier.java |
1 | 29 (3%) | 12 (8%) | 2023-06-02 |
| core/src/main/java/org/apache/rocketmq/streams/core/running/RocketMQClient.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/SinkSupplier.java |
1 | 8 (12%) | 19 (5%) | 2023-02-14 |
| core/src/main/java/org/apache/rocketmq/streams/core/RocketMQStream.java core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java |
1 | 20 (5%) | 51 (1%) | 2023-02-14 |
| core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AbstractWindowFire.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/SinkSupplier.java |
1 | 5 (20%) | 19 (5%) | 2023-02-14 |
| core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java |
1 | 21 (4%) | 10 (10%) | 2023-05-22 |
