apache / rocketmq-streams
File Change Frequency

File change frequency (churn) shows the distribution of file updates (days with at least one commit).

Overview
File Change Frequency Overall
  • There are 95 files with 5,796 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 0 files changed 51-100 times (0 lines of code)
    • 7 files changed 21-50 times (1,428 lines of code)
    • 46 files changed 6-20 times (3,102 lines of code)
    • 42 files changed 1-5 times (1,266 lines of code)
0% | 0% | 24% | 53% | 21%
Legend:
101+
51-100
21-50
6-20
1-5

explore: grouped by folders | grouped by update frequency | data
Contributors Count Frequency Overall
  • There are 95 files with 5,796 lines of code.
    • 0 files changed by more than 25 contributors (0 lines of code)
    • 0 files changed by 11-25 contributors (0 lines of code)
    • 2 files changed by 6-10 contributors (264 lines of code)
    • 38 files changed by 2-5 contributors (3,596 lines of code)
    • 55 files changed by 1 contributor (1,936 lines of code)
0% | 0% | 4% | 62% | 33%
Legend:
26+
11-25
6-10
2-5
1

explore: grouped by folders | grouped by contributors count | data
File Change Frequency per File Extension
java, xml, txt, sh, gitignore, md, json, yml, yaml
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 0% | 24% | 53% | 21%
xml0% | 0% | 0% | 100% | 0%
File Change Frequency per Logical Decomposition
primary
primary (file change frequency)
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
core0% | 0% | 24% | 53% | 21%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
RocketMQStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/state
 314 13 2022-10-20 2023-06-20 37 5 unclerangoo@gmail.com karp@apache.org
WorkerThread.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 222 10 2022-10-19 2023-06-02 35 4 unclerangoo@gmail.com nizeze.ni@alibaba-inc.com
WindowAggregateSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 243 9 2022-10-19 2023-06-02 34 5 unclerangoo@gmail.com karp@apache.org
Utils.java
in core/src/main/java/org/apache/rocketmq/streams/core/util
 115 7 2022-10-20 2023-02-08 24 2 unclerangoo@gmail.com unclerangoo@gmail.com
RocksDBStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/state
 161 7 2022-10-19 2023-02-08 23 2 unclerangoo@gmail.com unclerangoo@gmail.com
GroupedStreamImpl.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 196 14 2022-10-19 2023-06-02 22 6 unclerangoo@gmail.com nizeze.ni@alibaba-inc.com
WindowStreamImpl.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 177 9 2022-10-19 2023-03-02 21 3 unclerangoo@gmail.com unclerangoo@gmail.com
OperatorNameMaker.java
in core/src/main/java/org/apache/rocketmq/streams/core/util
 34 2 2022-11-09 2023-02-14 20 2 unclerangoo@gmail.com unclerangoo@gmail.com
AbstractWindowProcessor.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 53 2 2022-10-19 2023-02-14 20 2 unclerangoo@gmail.com unclerangoo@gmail.com
Constant.java
in core/src/main/java/org/apache/rocketmq/streams/core/common
 19 - 2022-10-19 2023-02-08 19 2 unclerangoo@gmail.com unclerangoo@gmail.com
JoinWindowAggregateSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 118 6 2022-11-10 2023-06-02 19 5 unclerangoo@gmail.com karp@apache.org
AggregateSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 68 5 2022-10-19 2023-02-05 18 2 unclerangoo@gmail.com jargon9@pku.edu.cn
StateStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/state
 19 - 2022-10-19 2023-01-06 16 1 unclerangoo@gmail.com unclerangoo@gmail.com
WindowStream.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 20 - 2022-10-19 2023-03-02 16 3 unclerangoo@gmail.com unclerangoo@gmail.com
AbstractProcessor.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 94 6 2022-10-19 2023-02-05 16 2 unclerangoo@gmail.com jargon9@pku.edu.cn
StreamContextImpl.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 125 14 2022-10-19 2023-02-05 16 2 unclerangoo@gmail.com jargon9@pku.edu.cn
AbstractStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/state
 161 21 2022-10-19 2023-05-08 16 3 unclerangoo@gmail.com karp@apache.org
StreamConfig.java
in core/src/main/java/org/apache/rocketmq/streams/core/metadata
 13 - 2022-10-19 2023-06-02 15 4 unclerangoo@gmail.com nizeze.ni@alibaba-inc.com
SinkSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 70 5 2022-10-19 2023-02-14 15 1 unclerangoo@gmail.com unclerangoo@gmail.com
RocketMQStream.java
in core/src/main/java/org/apache/rocketmq/streams/core
 60 4 2022-10-19 2023-02-14 14 1 unclerangoo@gmail.com unclerangoo@gmail.com
MessageQueueListenerWrapper.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 68 5 2022-10-19 2023-07-07 14 6 unclerangoo@gmail.com 44845151+elenacliu@users.no...
RStreamImpl.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 102 12 2022-10-19 2023-02-16 14 1 unclerangoo@gmail.com unclerangoo@gmail.com
WindowAccumulatorSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 245 9 2022-12-27 2023-06-02 14 5 unclerangoo@gmail.com karp@apache.org
StreamContext.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 22 - 2022-10-19 2023-02-05 13 2 unclerangoo@gmail.com jargon9@pku.edu.cn
SourceSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 55 6 2022-10-19 2023-02-05 13 2 unclerangoo@gmail.com jargon9@pku.edu.cn
RStream.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 19 - 2022-10-19 2023-02-16 12 1 unclerangoo@gmail.com unclerangoo@gmail.com
ValueChangeSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 36 4 2022-10-19 2023-06-02 12 5 unclerangoo@gmail.com nizeze.ni@alibaba-inc.com
ShuffleProcessorNode.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual
 32 3 2022-10-19 2023-01-06 11 1 unclerangoo@gmail.com unclerangoo@gmail.com
JoinedStream.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 136 9 2022-11-09 2023-01-03 11 1 unclerangoo@gmail.com unclerangoo@gmail.com
RocketMQUtil.java
in core/src/main/java/org/apache/rocketmq/streams/core/util
 178 9 2022-12-09 2023-02-14 11 1 unclerangoo@gmail.com unclerangoo@gmail.com
GroupedStream.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 24 - 2022-10-19 2023-06-02 10 4 unclerangoo@gmail.com nizeze.ni@alibaba-inc.com
StreamBuilder.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 40 4 2022-10-19 2023-02-14 10 1 unclerangoo@gmail.com unclerangoo@gmail.com
KVJsonDeserializer.java
in core/src/main/java/org/apache/rocketmq/streams/core/serialization/deImpl
 47 3 2022-10-21 2023-02-05 9 2 unclerangoo@gmail.com jargon9@pku.edu.cn
Data.java
in core/src/main/java/org/apache/rocketmq/streams/core/metadata
 52 12 2022-10-25 2023-01-03 9 1 unclerangoo@gmail.com unclerangoo@gmail.com
Pipeline.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 70 11 2022-10-19 2023-02-14 9 1 unclerangoo@gmail.com unclerangoo@gmail.com
KeySelectSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 28 4 2022-10-19 2023-01-03 8 1 unclerangoo@gmail.com unclerangoo@gmail.com
TimestampSelectorSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 30 4 2022-10-25 2023-02-05 8 2 unclerangoo@gmail.com jargon9@pku.edu.cn
logback.xml
in core/src/main/resources
 36 - 2022-11-06 2023-02-08 8 1 unclerangoo@gmail.com unclerangoo@gmail.com
JoinWindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 170 4 2023-01-30 2023-02-14 8 2 unclerangoo@gmail.com unclerangoo@gmail.com
IdleWindowScaner.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 241 19 2023-02-01 2023-07-19 8 4 unclerangoo@gmail.com karp@apache.org
AggregateAction.java
in core/src/main/java/org/apache/rocketmq/streams/core/function
 4 - 2022-10-19 2023-01-03 7 1 unclerangoo@gmail.com unclerangoo@gmail.com
ForeachSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 28 4 2022-10-19 2022-12-18 7 1 unclerangoo@gmail.com unclerangoo@gmail.com
ShuffleProtocol.java
in core/src/main/java/org/apache/rocketmq/streams/core/serialization
 39 1 2022-10-19 2022-12-18 7 1 unclerangoo@gmail.com unclerangoo@gmail.com
KVJsonSerializer.java
in core/src/main/java/org/apache/rocketmq/streams/core/serialization/serImpl
 41 1 2022-10-21 2023-02-05 7 2 unclerangoo@gmail.com jargon9@pku.edu.cn
RocketMQClient.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 42 4 2022-10-19 2023-02-14 7 1 unclerangoo@gmail.com unclerangoo@gmail.com
TopologyBuilder.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology
 73 8 2022-10-19 2023-02-05 7 1 unclerangoo@gmail.com unclerangoo@gmail.com
FilterAction.java
in core/src/main/java/org/apache/rocketmq/streams/core/function
 5 - 2022-10-19 2023-01-06 6 1 unclerangoo@gmail.com unclerangoo@gmail.com
FilterSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 30 4 2022-10-19 2022-12-18 6 1 unclerangoo@gmail.com unclerangoo@gmail.com
MultiValueChangeSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 41 4 2023-01-05 2023-06-02 6 5 unclerangoo@gmail.com nizeze.ni@alibaba-inc.com
AggregateSessionWindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 63 2 2023-01-30 2023-07-19 6 3 unclerangoo@gmail.com karp@apache.org
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
GroupedStreamImpl.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 196 14 2022-10-19 2023-06-02 22 6 unclerangoo@gmail.com nizeze.ni@alibaba-inc.com
MessageQueueListenerWrapper.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 68 5 2022-10-19 2023-07-07 14 6 unclerangoo@gmail.com 44845151+elenacliu@users.no...
RocketMQStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/state
 314 13 2022-10-20 2023-06-20 37 5 unclerangoo@gmail.com karp@apache.org
WindowAggregateSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 243 9 2022-10-19 2023-06-02 34 5 unclerangoo@gmail.com karp@apache.org
JoinWindowAggregateSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 118 6 2022-11-10 2023-06-02 19 5 unclerangoo@gmail.com karp@apache.org
WindowAccumulatorSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 245 9 2022-12-27 2023-06-02 14 5 unclerangoo@gmail.com karp@apache.org
ValueChangeSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 36 4 2022-10-19 2023-06-02 12 5 unclerangoo@gmail.com nizeze.ni@alibaba-inc.com
MultiValueChangeSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 41 4 2023-01-05 2023-06-02 6 5 unclerangoo@gmail.com nizeze.ni@alibaba-inc.com
WorkerThread.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 222 10 2022-10-19 2023-06-02 35 4 unclerangoo@gmail.com nizeze.ni@alibaba-inc.com
StreamConfig.java
in core/src/main/java/org/apache/rocketmq/streams/core/metadata
 13 - 2022-10-19 2023-06-02 15 4 unclerangoo@gmail.com nizeze.ni@alibaba-inc.com
GroupedStream.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 24 - 2022-10-19 2023-06-02 10 4 unclerangoo@gmail.com nizeze.ni@alibaba-inc.com
IdleWindowScaner.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 241 19 2023-02-01 2023-07-19 8 4 unclerangoo@gmail.com karp@apache.org
WindowStreamImpl.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 177 9 2022-10-19 2023-03-02 21 3 unclerangoo@gmail.com unclerangoo@gmail.com
WindowStream.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 20 - 2022-10-19 2023-03-02 16 3 unclerangoo@gmail.com unclerangoo@gmail.com
AbstractStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/state
 161 21 2022-10-19 2023-05-08 16 3 unclerangoo@gmail.com karp@apache.org
AggregateSessionWindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 63 2 2023-01-30 2023-07-19 6 3 unclerangoo@gmail.com karp@apache.org
AccumulatorSessionWindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 65 2 2023-01-30 2023-07-19 6 3 unclerangoo@gmail.com karp@apache.org
Utils.java
in core/src/main/java/org/apache/rocketmq/streams/core/util
 115 7 2022-10-20 2023-02-08 24 2 unclerangoo@gmail.com unclerangoo@gmail.com
RocksDBStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/state
 161 7 2022-10-19 2023-02-08 23 2 unclerangoo@gmail.com unclerangoo@gmail.com
AbstractWindowProcessor.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 53 2 2022-10-19 2023-02-14 20 2 unclerangoo@gmail.com unclerangoo@gmail.com
OperatorNameMaker.java
in core/src/main/java/org/apache/rocketmq/streams/core/util
 34 2 2022-11-09 2023-02-14 20 2 unclerangoo@gmail.com unclerangoo@gmail.com
Constant.java
in core/src/main/java/org/apache/rocketmq/streams/core/common
 19 - 2022-10-19 2023-02-08 19 2 unclerangoo@gmail.com unclerangoo@gmail.com
AggregateSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 68 5 2022-10-19 2023-02-05 18 2 unclerangoo@gmail.com jargon9@pku.edu.cn
AbstractProcessor.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 94 6 2022-10-19 2023-02-05 16 2 unclerangoo@gmail.com jargon9@pku.edu.cn
StreamContextImpl.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 125 14 2022-10-19 2023-02-05 16 2 unclerangoo@gmail.com jargon9@pku.edu.cn
StreamContext.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 22 - 2022-10-19 2023-02-05 13 2 unclerangoo@gmail.com jargon9@pku.edu.cn
SourceSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 55 6 2022-10-19 2023-02-05 13 2 unclerangoo@gmail.com jargon9@pku.edu.cn
KVJsonDeserializer.java
in core/src/main/java/org/apache/rocketmq/streams/core/serialization/deImpl
 47 3 2022-10-21 2023-02-05 9 2 unclerangoo@gmail.com jargon9@pku.edu.cn
TimestampSelectorSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 30 4 2022-10-25 2023-02-05 8 2 unclerangoo@gmail.com jargon9@pku.edu.cn
JoinWindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 170 4 2023-01-30 2023-02-14 8 2 unclerangoo@gmail.com unclerangoo@gmail.com
KVJsonSerializer.java
in core/src/main/java/org/apache/rocketmq/streams/core/serialization/serImpl
 41 1 2022-10-21 2023-02-05 7 2 unclerangoo@gmail.com jargon9@pku.edu.cn
JoinAggregateSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 117 8 2022-12-27 2023-02-05 6 2 unclerangoo@gmail.com jargon9@pku.edu.cn
AccumulatorSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 69 5 2023-01-01 2023-02-05 6 2 unclerangoo@gmail.com jargon9@pku.edu.cn
AggregateWindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 57 2 2023-01-30 2023-02-08 5 2 unclerangoo@gmail.com unclerangoo@gmail.com
AccumulatorWindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 59 2 2023-01-30 2023-02-08 5 2 unclerangoo@gmail.com unclerangoo@gmail.com
WindowStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 73 5 2023-01-03 2023-02-05 4 2 unclerangoo@gmail.com jargon9@pku.edu.cn
Time.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 41 11 2023-01-03 2023-02-05 4 2 unclerangoo@gmail.com jargon9@pku.edu.cn
WindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 11 1 2023-01-30 2023-02-05 4 2 unclerangoo@gmail.com jargon9@pku.edu.cn
WindowKey.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 98 14 2023-01-03 2023-02-05 4 2 unclerangoo@gmail.com jargon9@pku.edu.cn
AvgAccumulator.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator
 54 8 2023-02-05 2023-02-09 2 2 jargon9@pku.edu.cn unclerangoo@gmail.com
StateStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/state
 19 - 2022-10-19 2023-01-06 16 1 unclerangoo@gmail.com unclerangoo@gmail.com
SinkSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 70 5 2022-10-19 2023-02-14 15 1 unclerangoo@gmail.com unclerangoo@gmail.com
RStreamImpl.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 102 12 2022-10-19 2023-02-16 14 1 unclerangoo@gmail.com unclerangoo@gmail.com
RocketMQStream.java
in core/src/main/java/org/apache/rocketmq/streams/core
 60 4 2022-10-19 2023-02-14 14 1 unclerangoo@gmail.com unclerangoo@gmail.com
RStream.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 19 - 2022-10-19 2023-02-16 12 1 unclerangoo@gmail.com unclerangoo@gmail.com
ShuffleProcessorNode.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual
 32 3 2022-10-19 2023-01-06 11 1 unclerangoo@gmail.com unclerangoo@gmail.com
JoinedStream.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 136 9 2022-11-09 2023-01-03 11 1 unclerangoo@gmail.com unclerangoo@gmail.com
RocketMQUtil.java
in core/src/main/java/org/apache/rocketmq/streams/core/util
 178 9 2022-12-09 2023-02-14 11 1 unclerangoo@gmail.com unclerangoo@gmail.com
StreamBuilder.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 40 4 2022-10-19 2023-02-14 10 1 unclerangoo@gmail.com unclerangoo@gmail.com
Pipeline.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 70 11 2022-10-19 2023-02-14 9 1 unclerangoo@gmail.com unclerangoo@gmail.com
Files With Least Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
RocketMQUtil.java
in core/src/main/java/org/apache/rocketmq/streams/core/util
 178 9 2022-12-09 2023-02-14 11 1 unclerangoo@gmail.com unclerangoo@gmail.com
WindowState.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 175 17 2023-01-03 2023-01-03 1 1 unclerangoo@gmail.com unclerangoo@gmail.com
JoinedStream.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 136 9 2022-11-09 2023-01-03 11 1 unclerangoo@gmail.com unclerangoo@gmail.com
RStreamImpl.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 102 12 2022-10-19 2023-02-16 14 1 unclerangoo@gmail.com unclerangoo@gmail.com
TopologyBuilder.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology
 73 8 2022-10-19 2023-02-05 7 1 unclerangoo@gmail.com unclerangoo@gmail.com
Pipeline.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 70 11 2022-10-19 2023-02-14 9 1 unclerangoo@gmail.com unclerangoo@gmail.com
SinkSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 70 5 2022-10-19 2023-02-14 15 1 unclerangoo@gmail.com unclerangoo@gmail.com
WindowInfo.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 63 15 2023-01-03 2023-01-03 1 1 unclerangoo@gmail.com unclerangoo@gmail.com
RocketMQStream.java
in core/src/main/java/org/apache/rocketmq/streams/core
 60 4 2022-10-19 2023-02-14 14 1 unclerangoo@gmail.com unclerangoo@gmail.com
ProcessorNode.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual
 56 8 2022-10-19 2023-02-14 5 1 unclerangoo@gmail.com unclerangoo@gmail.com
Data.java
in core/src/main/java/org/apache/rocketmq/streams/core/metadata
 52 12 2022-10-25 2023-01-03 9 1 unclerangoo@gmail.com unclerangoo@gmail.com
AbstractGraphNode.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual
 49 7 2022-10-19 2022-12-18 3 1 unclerangoo@gmail.com unclerangoo@gmail.com
RocketMQClient.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 42 4 2022-10-19 2023-02-14 7 1 unclerangoo@gmail.com unclerangoo@gmail.com
StreamBuilder.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 40 4 2022-10-19 2023-02-14 10 1 unclerangoo@gmail.com unclerangoo@gmail.com
ShuffleProtocol.java
in core/src/main/java/org/apache/rocketmq/streams/core/serialization
 39 1 2022-10-19 2022-12-18 7 1 unclerangoo@gmail.com unclerangoo@gmail.com
logback.xml
in core/src/main/resources
 36 - 2022-11-06 2023-02-08 8 1 unclerangoo@gmail.com unclerangoo@gmail.com
PrintSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 36 3 2022-10-19 2022-12-18 5 1 unclerangoo@gmail.com unclerangoo@gmail.com
MinAccumulator.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator
 36 6 2022-12-27 2023-01-03 2 1 unclerangoo@gmail.com unclerangoo@gmail.com
ShuffleProcessorNode.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual
 32 3 2022-10-19 2023-01-06 11 1 unclerangoo@gmail.com unclerangoo@gmail.com
AddTagSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 32 5 2022-11-10 2022-12-18 3 1 unclerangoo@gmail.com unclerangoo@gmail.com
Pair.java
in core/src/main/java/org/apache/rocketmq/streams/core/util
 31 6 2022-10-27 2022-12-18 5 1 unclerangoo@gmail.com unclerangoo@gmail.com
FilterSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 30 4 2022-10-19 2022-12-18 6 1 unclerangoo@gmail.com unclerangoo@gmail.com
Window.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 30 6 2023-01-03 2023-01-03 1 1 unclerangoo@gmail.com unclerangoo@gmail.com
CountAccumulator.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator
 29 6 2022-12-27 2023-01-03 2 1 unclerangoo@gmail.com unclerangoo@gmail.com
SumAggregate.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 28 2 2023-01-01 2023-01-03 2 1 unclerangoo@gmail.com unclerangoo@gmail.com
KeySelectSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 28 4 2022-10-19 2023-01-03 8 1 unclerangoo@gmail.com unclerangoo@gmail.com
ForeachSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 28 4 2022-10-19 2022-12-18 7 1 unclerangoo@gmail.com unclerangoo@gmail.com
SourceFactory.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/real
 24 3 2022-10-19 2022-12-18 3 1 unclerangoo@gmail.com unclerangoo@gmail.com
AbstractWindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 24 2 2023-02-03 2023-02-14 4 1 unclerangoo@gmail.com unclerangoo@gmail.com
SourceGraphNode.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual
 23 3 2022-10-19 2023-01-06 4 1 unclerangoo@gmail.com unclerangoo@gmail.com
SinkGraphNode.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual
 23 3 2022-10-19 2023-01-06 4 1 unclerangoo@gmail.com unclerangoo@gmail.com
WindowBuilder.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 23 3 2023-01-03 2023-01-03 1 1 unclerangoo@gmail.com unclerangoo@gmail.com
SinkFactory.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/real
 22 3 2022-10-19 2022-12-18 3 1 unclerangoo@gmail.com unclerangoo@gmail.com
ProcessorFactory.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/real
 21 3 2022-10-19 2022-12-18 3 1 unclerangoo@gmail.com unclerangoo@gmail.com
RStream.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 19 - 2022-10-19 2023-02-16 12 1 unclerangoo@gmail.com unclerangoo@gmail.com
StateStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/state
 19 - 2022-10-19 2023-01-06 16 1 unclerangoo@gmail.com unclerangoo@gmail.com
RStreamsException.java
in core/src/main/java/org/apache/rocketmq/streams/core/exception
 18 5 2023-01-04 2023-01-04 1 1 unclerangoo@gmail.com unclerangoo@gmail.com
DeserializeThrowable.java
in core/src/main/java/org/apache/rocketmq/streams/core/exception
 18 5 2023-01-04 2023-01-04 1 1 unclerangoo@gmail.com unclerangoo@gmail.com
RecoverStateStoreThrowable.java
in core/src/main/java/org/apache/rocketmq/streams/core/exception
 17 5 2023-01-04 2023-01-04 1 1 unclerangoo@gmail.com unclerangoo@gmail.com
DataProcessThrowable.java
in core/src/main/java/org/apache/rocketmq/streams/core/exception
 17 5 2023-01-04 2023-01-04 1 1 unclerangoo@gmail.com unclerangoo@gmail.com
GraphNode.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual
 12 - 2022-10-19 2022-12-18 3 1 unclerangoo@gmail.com unclerangoo@gmail.com
Accumulator.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator
 8 - 2022-12-27 2023-01-06 3 1 unclerangoo@gmail.com unclerangoo@gmail.com
Processor.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 7 - 2022-10-19 2023-01-04 4 1 unclerangoo@gmail.com unclerangoo@gmail.com
RealProcessorFactory.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/real
 7 - 2022-10-19 2022-12-18 3 1 unclerangoo@gmail.com unclerangoo@gmail.com
KeyValueDeserializer.java
in core/src/main/java/org/apache/rocketmq/streams/core/serialization
 7 1 2022-10-19 2022-12-18 3 1 unclerangoo@gmail.com unclerangoo@gmail.com
ForeachAction.java
in core/src/main/java/org/apache/rocketmq/streams/core/function
 5 - 2022-10-19 2022-12-18 4 1 unclerangoo@gmail.com unclerangoo@gmail.com
FilterAction.java
in core/src/main/java/org/apache/rocketmq/streams/core/function
 5 - 2022-10-19 2023-01-06 6 1 unclerangoo@gmail.com unclerangoo@gmail.com
SelectAction.java
in core/src/main/java/org/apache/rocketmq/streams/core/function
 5 - 2022-12-26 2023-01-03 2 1 unclerangoo@gmail.com unclerangoo@gmail.com
JoinType.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 5 - 2023-01-03 2023-01-03 1 1 unclerangoo@gmail.com unclerangoo@gmail.com
StreamType.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 5 - 2023-01-03 2023-01-03 1 1 unclerangoo@gmail.com unclerangoo@gmail.com
Correlations

File Size vs. Number of Changes: 95 points

core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AccumulatorSessionWindowFire.java x: 65 lines of code y: 6 # changes core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AggregateSessionWindowFire.java x: 63 lines of code y: 6 # changes core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java x: 241 lines of code y: 8 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java x: 118 lines of code y: 19 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java x: 245 lines of code y: 14 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java x: 243 lines of code y: 34 # changes core/src/main/java/org/apache/rocketmq/streams/core/running/MessageQueueListenerWrapper.java x: 68 lines of code y: 14 # changes core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java x: 314 lines of code y: 37 # changes core/src/main/java/org/apache/rocketmq/streams/core/metadata/StreamConfig.java x: 13 lines of code y: 15 # changes core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java x: 222 lines of code y: 35 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/MultiValueChangeSupplier.java x: 41 lines of code y: 6 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ValueChangeSupplier.java x: 36 lines of code y: 12 # changes core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStream.java x: 24 lines of code y: 10 # changes core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java x: 196 lines of code y: 22 # changes core/src/main/java/org/apache/rocketmq/streams/core/state/AbstractStore.java x: 161 lines of code y: 16 # changes core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStream.java x: 20 lines of code y: 16 # changes core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java x: 177 lines of code y: 21 # changes core/src/main/java/org/apache/rocketmq/streams/core/rstream/RStream.java x: 19 lines of code y: 12 # changes core/src/main/java/org/apache/rocketmq/streams/core/rstream/RStreamImpl.java x: 102 lines of code y: 14 # changes core/src/main/java/org/apache/rocketmq/streams/core/RocketMQStream.java x: 60 lines of code y: 14 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/SinkSupplier.java x: 70 lines of code y: 15 # changes core/src/main/java/org/apache/rocketmq/streams/core/rstream/Pipeline.java x: 70 lines of code y: 9 # changes core/src/main/java/org/apache/rocketmq/streams/core/rstream/StreamBuilder.java x: 40 lines of code y: 10 # changes core/src/main/java/org/apache/rocketmq/streams/core/running/AbstractWindowProcessor.java x: 53 lines of code y: 20 # changes core/src/main/java/org/apache/rocketmq/streams/core/running/RocketMQClient.java x: 42 lines of code y: 7 # changes core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual/ProcessorNode.java x: 56 lines of code y: 5 # changes core/src/main/java/org/apache/rocketmq/streams/core/util/OperatorNameMaker.java x: 34 lines of code y: 20 # changes core/src/main/java/org/apache/rocketmq/streams/core/util/RocketMQUtil.java x: 178 lines of code y: 11 # changes core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AbstractWindowFire.java x: 24 lines of code y: 4 # changes core/src/main/java/org/apache/rocketmq/streams/core/window/fire/JoinWindowFire.java x: 170 lines of code y: 8 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator/AvgAccumulator.java x: 54 lines of code y: 2 # changes core/src/main/resources/logback.xml x: 36 lines of code y: 8 # changes core/src/main/java/org/apache/rocketmq/streams/core/common/Constant.java x: 19 lines of code y: 19 # changes core/src/main/java/org/apache/rocketmq/streams/core/state/RocksDBStore.java x: 161 lines of code y: 23 # changes core/src/main/java/org/apache/rocketmq/streams/core/util/Utils.java x: 115 lines of code y: 24 # changes core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AccumulatorWindowFire.java x: 59 lines of code y: 5 # changes core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AggregateWindowFire.java x: 57 lines of code y: 5 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/AccumulatorSupplier.java x: 69 lines of code y: 6 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/AggregateSupplier.java x: 68 lines of code y: 18 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinAggregateSupplier.java x: 117 lines of code y: 6 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/SourceSupplier.java x: 55 lines of code y: 13 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/TimestampSelectorSupplier.java x: 30 lines of code y: 8 # changes core/src/main/java/org/apache/rocketmq/streams/core/running/AbstractProcessor.java x: 94 lines of code y: 16 # changes core/src/main/java/org/apache/rocketmq/streams/core/running/StreamContext.java x: 22 lines of code y: 13 # changes core/src/main/java/org/apache/rocketmq/streams/core/running/StreamContextImpl.java x: 125 lines of code y: 16 # changes core/src/main/java/org/apache/rocketmq/streams/core/serialization/deImpl/KVJsonDeserializer.java x: 47 lines of code y: 9 # changes core/src/main/java/org/apache/rocketmq/streams/core/serialization/serImpl/KVJsonSerializer.java x: 41 lines of code y: 7 # changes core/src/main/java/org/apache/rocketmq/streams/core/window/Time.java x: 41 lines of code y: 4 # changes core/src/main/java/org/apache/rocketmq/streams/core/window/WindowKey.java x: 98 lines of code y: 4 # changes core/src/main/java/org/apache/rocketmq/streams/core/window/WindowStore.java x: 73 lines of code y: 4 # changes core/src/main/java/org/apache/rocketmq/streams/core/window/fire/WindowFire.java x: 11 lines of code y: 4 # changes core/src/main/java/org/apache/rocketmq/streams/core/topology/TopologyBuilder.java x: 73 lines of code y: 7 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/FilterAction.java x: 5 lines of code y: 6 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator/Accumulator.java x: 8 lines of code y: 3 # changes core/src/main/java/org/apache/rocketmq/streams/core/state/StateStore.java x: 19 lines of code y: 16 # changes core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual/ShuffleProcessorNode.java x: 32 lines of code y: 11 # changes core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual/SinkGraphNode.java x: 23 lines of code y: 4 # changes core/src/main/java/org/apache/rocketmq/streams/core/exception/DataProcessThrowable.java x: 17 lines of code y: 1 # changes core/src/main/java/org/apache/rocketmq/streams/core/exception/DeserializeThrowable.java x: 18 lines of code y: 1 # changes core/src/main/java/org/apache/rocketmq/streams/core/running/Processor.java x: 7 lines of code y: 4 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/AggregateAction.java x: 4 lines of code y: 7 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/SelectAction.java x: 5 lines of code y: 2 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator/CountAccumulator.java x: 29 lines of code y: 2 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator/MinAccumulator.java x: 36 lines of code y: 2 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/KeySelectSupplier.java x: 28 lines of code y: 8 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/SumAggregate.java x: 28 lines of code y: 2 # changes core/src/main/java/org/apache/rocketmq/streams/core/metadata/Data.java x: 52 lines of code y: 9 # changes core/src/main/java/org/apache/rocketmq/streams/core/rstream/JoinedStream.java x: 136 lines of code y: 11 # changes core/src/main/java/org/apache/rocketmq/streams/core/window/JoinType.java x: 5 lines of code y: 1 # changes core/src/main/java/org/apache/rocketmq/streams/core/window/Window.java x: 30 lines of code y: 1 # changes core/src/main/java/org/apache/rocketmq/streams/core/window/WindowBuilder.java x: 23 lines of code y: 1 # changes core/src/main/java/org/apache/rocketmq/streams/core/window/WindowInfo.java x: 63 lines of code y: 1 # changes core/src/main/java/org/apache/rocketmq/streams/core/window/WindowState.java x: 175 lines of code y: 1 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/ForeachAction.java x: 5 lines of code y: 4 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/ValueJoinAction.java x: 4 lines of code y: 4 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/ValueMapperAction.java x: 4 lines of code y: 5 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/AddTagSupplier.java x: 32 lines of code y: 3 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/FilterSupplier.java x: 30 lines of code y: 6 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ForeachSupplier.java x: 28 lines of code y: 7 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/PrintSupplier.java x: 36 lines of code y: 5 # changes core/src/main/java/org/apache/rocketmq/streams/core/serialization/KeyValueDeserializer.java x: 7 lines of code y: 3 # changes core/src/main/java/org/apache/rocketmq/streams/core/serialization/KeyValueSerializer.java x: 4 lines of code y: 2 # changes core/src/main/java/org/apache/rocketmq/streams/core/serialization/ShuffleProtocol.java x: 39 lines of code y: 7 # changes core/src/main/java/org/apache/rocketmq/streams/core/topology/real/ProcessorFactory.java x: 21 lines of code y: 3 # changes core/src/main/java/org/apache/rocketmq/streams/core/topology/real/SinkFactory.java x: 22 lines of code y: 3 # changes core/src/main/java/org/apache/rocketmq/streams/core/topology/real/SourceFactory.java x: 24 lines of code y: 3 # changes core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual/AbstractGraphNode.java x: 49 lines of code y: 3 # changes core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual/GraphNode.java x: 12 lines of code y: 3 # changes core/src/main/java/org/apache/rocketmq/streams/core/util/Pair.java x: 31 lines of code y: 5 # changes
37.0
# changes
  min: 1.0
  average: 8.76
  25th percentile: 3.0
  median: 6.0
  75th percentile: 13.0
  max: 37.0
0 314.0
lines of code
min: 4.0 | average: 61.01 | 25th percentile: 19.0 | median: 36.0 | 75th percentile: 70.0 | max: 314.0

Number of Contributors vs. Number of Changes: 95 points

core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AccumulatorSessionWindowFire.java x: 3 # contributors y: 6 # changes core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java x: 4 # contributors y: 8 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java x: 5 # contributors y: 19 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java x: 5 # contributors y: 14 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java x: 5 # contributors y: 34 # changes core/src/main/java/org/apache/rocketmq/streams/core/running/MessageQueueListenerWrapper.java x: 6 # contributors y: 14 # changes core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java x: 5 # contributors y: 37 # changes core/src/main/java/org/apache/rocketmq/streams/core/metadata/StreamConfig.java x: 4 # contributors y: 15 # changes core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java x: 4 # contributors y: 35 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/MultiValueChangeSupplier.java x: 5 # contributors y: 6 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ValueChangeSupplier.java x: 5 # contributors y: 12 # changes core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStream.java x: 4 # contributors y: 10 # changes core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java x: 6 # contributors y: 22 # changes core/src/main/java/org/apache/rocketmq/streams/core/state/AbstractStore.java x: 3 # contributors y: 16 # changes core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java x: 3 # contributors y: 21 # changes core/src/main/java/org/apache/rocketmq/streams/core/rstream/RStream.java x: 1 # contributors y: 12 # changes core/src/main/java/org/apache/rocketmq/streams/core/rstream/RStreamImpl.java x: 1 # contributors y: 14 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/SinkSupplier.java x: 1 # contributors y: 15 # changes core/src/main/java/org/apache/rocketmq/streams/core/rstream/Pipeline.java x: 1 # contributors y: 9 # changes core/src/main/java/org/apache/rocketmq/streams/core/rstream/StreamBuilder.java x: 1 # contributors y: 10 # changes core/src/main/java/org/apache/rocketmq/streams/core/running/AbstractWindowProcessor.java x: 2 # contributors y: 20 # changes core/src/main/java/org/apache/rocketmq/streams/core/running/RocketMQClient.java x: 1 # contributors y: 7 # changes core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual/ProcessorNode.java x: 1 # contributors y: 5 # changes core/src/main/java/org/apache/rocketmq/streams/core/util/RocketMQUtil.java x: 1 # contributors y: 11 # changes core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AbstractWindowFire.java x: 1 # contributors y: 4 # changes core/src/main/java/org/apache/rocketmq/streams/core/window/fire/JoinWindowFire.java x: 2 # contributors y: 8 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator/AvgAccumulator.java x: 2 # contributors y: 2 # changes core/src/main/resources/logback.xml x: 1 # contributors y: 8 # changes core/src/main/java/org/apache/rocketmq/streams/core/common/Constant.java x: 2 # contributors y: 19 # changes core/src/main/java/org/apache/rocketmq/streams/core/state/RocksDBStore.java x: 2 # contributors y: 23 # changes core/src/main/java/org/apache/rocketmq/streams/core/util/Utils.java x: 2 # contributors y: 24 # changes core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AccumulatorWindowFire.java x: 2 # contributors y: 5 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/AccumulatorSupplier.java x: 2 # contributors y: 6 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/AggregateSupplier.java x: 2 # contributors y: 18 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/SourceSupplier.java x: 2 # contributors y: 13 # changes core/src/main/java/org/apache/rocketmq/streams/core/running/AbstractProcessor.java x: 2 # contributors y: 16 # changes core/src/main/java/org/apache/rocketmq/streams/core/serialization/deImpl/KVJsonDeserializer.java x: 2 # contributors y: 9 # changes core/src/main/java/org/apache/rocketmq/streams/core/serialization/serImpl/KVJsonSerializer.java x: 2 # contributors y: 7 # changes core/src/main/java/org/apache/rocketmq/streams/core/window/Time.java x: 2 # contributors y: 4 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/FilterAction.java x: 1 # contributors y: 6 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator/Accumulator.java x: 1 # contributors y: 3 # changes core/src/main/java/org/apache/rocketmq/streams/core/state/StateStore.java x: 1 # contributors y: 16 # changes core/src/main/java/org/apache/rocketmq/streams/core/exception/DataProcessThrowable.java x: 1 # contributors y: 1 # changes core/src/main/java/org/apache/rocketmq/streams/core/function/SelectAction.java x: 1 # contributors y: 2 # changes
37.0
# changes
  min: 1.0
  average: 8.76
  25th percentile: 3.0
  median: 6.0
  75th percentile: 13.0
  max: 37.0
0 6.0
# contributors
min: 1.0 | average: 1.83 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 6.0

Number of Contributors vs. File Size: 95 points

core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AccumulatorSessionWindowFire.java x: 3 # contributors y: 65 lines of code core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AggregateSessionWindowFire.java x: 3 # contributors y: 63 lines of code core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java x: 4 # contributors y: 241 lines of code core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java x: 5 # contributors y: 118 lines of code core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java x: 5 # contributors y: 245 lines of code core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java x: 5 # contributors y: 243 lines of code core/src/main/java/org/apache/rocketmq/streams/core/running/MessageQueueListenerWrapper.java x: 6 # contributors y: 68 lines of code core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java x: 5 # contributors y: 314 lines of code core/src/main/java/org/apache/rocketmq/streams/core/metadata/StreamConfig.java x: 4 # contributors y: 13 lines of code core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java x: 4 # contributors y: 222 lines of code core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/MultiValueChangeSupplier.java x: 5 # contributors y: 41 lines of code core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ValueChangeSupplier.java x: 5 # contributors y: 36 lines of code core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStream.java x: 4 # contributors y: 24 lines of code core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java x: 6 # contributors y: 196 lines of code core/src/main/java/org/apache/rocketmq/streams/core/state/AbstractStore.java x: 3 # contributors y: 161 lines of code core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStream.java x: 3 # contributors y: 20 lines of code core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java x: 3 # contributors y: 177 lines of code core/src/main/java/org/apache/rocketmq/streams/core/rstream/RStream.java x: 1 # contributors y: 19 lines of code core/src/main/java/org/apache/rocketmq/streams/core/rstream/RStreamImpl.java x: 1 # contributors y: 102 lines of code core/src/main/java/org/apache/rocketmq/streams/core/RocketMQStream.java x: 1 # contributors y: 60 lines of code core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/SinkSupplier.java x: 1 # contributors y: 70 lines of code core/src/main/java/org/apache/rocketmq/streams/core/rstream/StreamBuilder.java x: 1 # contributors y: 40 lines of code core/src/main/java/org/apache/rocketmq/streams/core/running/AbstractWindowProcessor.java x: 2 # contributors y: 53 lines of code core/src/main/java/org/apache/rocketmq/streams/core/running/RocketMQClient.java x: 1 # contributors y: 42 lines of code core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual/ProcessorNode.java x: 1 # contributors y: 56 lines of code core/src/main/java/org/apache/rocketmq/streams/core/util/OperatorNameMaker.java x: 2 # contributors y: 34 lines of code core/src/main/java/org/apache/rocketmq/streams/core/util/RocketMQUtil.java x: 1 # contributors y: 178 lines of code core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AbstractWindowFire.java x: 1 # contributors y: 24 lines of code core/src/main/java/org/apache/rocketmq/streams/core/window/fire/JoinWindowFire.java x: 2 # contributors y: 170 lines of code core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator/AvgAccumulator.java x: 2 # contributors y: 54 lines of code core/src/main/resources/logback.xml x: 1 # contributors y: 36 lines of code core/src/main/java/org/apache/rocketmq/streams/core/common/Constant.java x: 2 # contributors y: 19 lines of code core/src/main/java/org/apache/rocketmq/streams/core/state/RocksDBStore.java x: 2 # contributors y: 161 lines of code core/src/main/java/org/apache/rocketmq/streams/core/util/Utils.java x: 2 # contributors y: 115 lines of code core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AccumulatorWindowFire.java x: 2 # contributors y: 59 lines of code core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AggregateWindowFire.java x: 2 # contributors y: 57 lines of code core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/AccumulatorSupplier.java x: 2 # contributors y: 69 lines of code core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinAggregateSupplier.java x: 2 # contributors y: 117 lines of code core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/SourceSupplier.java x: 2 # contributors y: 55 lines of code core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/TimestampSelectorSupplier.java x: 2 # contributors y: 30 lines of code core/src/main/java/org/apache/rocketmq/streams/core/running/AbstractProcessor.java x: 2 # contributors y: 94 lines of code core/src/main/java/org/apache/rocketmq/streams/core/running/StreamContext.java x: 2 # contributors y: 22 lines of code core/src/main/java/org/apache/rocketmq/streams/core/running/StreamContextImpl.java x: 2 # contributors y: 125 lines of code core/src/main/java/org/apache/rocketmq/streams/core/serialization/deImpl/KVJsonDeserializer.java x: 2 # contributors y: 47 lines of code core/src/main/java/org/apache/rocketmq/streams/core/serialization/serImpl/KVJsonSerializer.java x: 2 # contributors y: 41 lines of code core/src/main/java/org/apache/rocketmq/streams/core/window/WindowKey.java x: 2 # contributors y: 98 lines of code core/src/main/java/org/apache/rocketmq/streams/core/window/WindowStore.java x: 2 # contributors y: 73 lines of code core/src/main/java/org/apache/rocketmq/streams/core/window/fire/WindowFire.java x: 2 # contributors y: 11 lines of code core/src/main/java/org/apache/rocketmq/streams/core/topology/TopologyBuilder.java x: 1 # contributors y: 73 lines of code core/src/main/java/org/apache/rocketmq/streams/core/function/FilterAction.java x: 1 # contributors y: 5 lines of code core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator/Accumulator.java x: 1 # contributors y: 8 lines of code core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual/ShuffleProcessorNode.java x: 1 # contributors y: 32 lines of code core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual/SinkGraphNode.java x: 1 # contributors y: 23 lines of code core/src/main/java/org/apache/rocketmq/streams/core/exception/DataProcessThrowable.java x: 1 # contributors y: 17 lines of code core/src/main/java/org/apache/rocketmq/streams/core/exception/DeserializeThrowable.java x: 1 # contributors y: 18 lines of code core/src/main/java/org/apache/rocketmq/streams/core/running/Processor.java x: 1 # contributors y: 7 lines of code core/src/main/java/org/apache/rocketmq/streams/core/function/AggregateAction.java x: 1 # contributors y: 4 lines of code core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator/CountAccumulator.java x: 1 # contributors y: 29 lines of code core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/KeySelectSupplier.java x: 1 # contributors y: 28 lines of code core/src/main/java/org/apache/rocketmq/streams/core/metadata/Data.java x: 1 # contributors y: 52 lines of code core/src/main/java/org/apache/rocketmq/streams/core/rstream/JoinedStream.java x: 1 # contributors y: 136 lines of code core/src/main/java/org/apache/rocketmq/streams/core/window/Window.java x: 1 # contributors y: 30 lines of code core/src/main/java/org/apache/rocketmq/streams/core/window/WindowInfo.java x: 1 # contributors y: 63 lines of code core/src/main/java/org/apache/rocketmq/streams/core/window/WindowState.java x: 1 # contributors y: 175 lines of code core/src/main/java/org/apache/rocketmq/streams/core/serialization/ShuffleProtocol.java x: 1 # contributors y: 39 lines of code core/src/main/java/org/apache/rocketmq/streams/core/topology/real/ProcessorFactory.java x: 1 # contributors y: 21 lines of code core/src/main/java/org/apache/rocketmq/streams/core/topology/real/SinkFactory.java x: 1 # contributors y: 22 lines of code core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual/AbstractGraphNode.java x: 1 # contributors y: 49 lines of code core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual/GraphNode.java x: 1 # contributors y: 12 lines of code
314.0
lines of code
  min: 4.0
  average: 61.01
  25th percentile: 19.0
  median: 36.0
  75th percentile: 70.0
  max: 314.0
0 6.0
# contributors
min: 1.0 | average: 1.83 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 6.0