apache / rocketmq-streams
File Size

The distribution of size of files (measured in lines of code).

Intro
Learn more...
File Size Overall
0% | 0% | 21% | 33% | 44%
Legend:
1001+
501-1000
201-500
101-200
1-100


explore: grouped by folders | grouped by size | sunburst | 3D view
File Size per Extension
1001+
501-1000
201-500
101-200
1-100
java0% | 0% | 21% | 33% | 44%
xml0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
core0% | 0% | 21% | 33% | 44%
Longest Files (Top 50)
File# lines# units
RocketMQStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/state
 314 13
WindowAccumulatorSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 245 9
WindowAggregateSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 243 9
IdleWindowScaner.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 241 19
WorkerThread.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 222 10
GroupedStreamImpl.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 196 14
RocketMQUtil.java
in core/src/main/java/org/apache/rocketmq/streams/core/util
 178 9
WindowStreamImpl.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 177 9
WindowState.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 175 17
JoinWindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 170 4
AbstractStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/state
 161 21
RocksDBStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/state
 161 7
JoinedStream.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 136 9
StreamContextImpl.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 125 14
JoinWindowAggregateSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 118 6
JoinAggregateSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 117 8
Utils.java
in core/src/main/java/org/apache/rocketmq/streams/core/util
 115 7
RStreamImpl.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 102 12
WindowKey.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 98 14
AbstractProcessor.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 94 6
TopologyBuilder.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology
 73 8
WindowStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 73 5
Pipeline.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 70 11
SinkSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 70 5
AccumulatorSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 69 5
MessageQueueListenerWrapper.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 68 5
AggregateSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 68 5
AccumulatorSessionWindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 65 2
WindowInfo.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 63 15
AggregateSessionWindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 63 2
RocketMQStream.java
in core/src/main/java/org/apache/rocketmq/streams/core
 60 4
AccumulatorWindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 59 2
AggregateWindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 57 2
ProcessorNode.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual
 56 8
SourceSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 55 6
AvgAccumulator.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator
 54 8
AbstractWindowProcessor.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 53 2
Data.java
in core/src/main/java/org/apache/rocketmq/streams/core/metadata
 52 12
AbstractGraphNode.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual
 49 7
KVJsonDeserializer.java
in core/src/main/java/org/apache/rocketmq/streams/core/serialization/deImpl
 47 3
RocketMQClient.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 42 4
KVJsonSerializer.java
in core/src/main/java/org/apache/rocketmq/streams/core/serialization/serImpl
 41 1
MultiValueChangeSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 41 4
Time.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 41 11
StreamBuilder.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 40 4
ShuffleProtocol.java
in core/src/main/java/org/apache/rocketmq/streams/core/serialization
 39 1
logback.xml
in core/src/main/resources
 36 -
ValueChangeSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 36 4
PrintSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 36 3
MinAccumulator.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator
 36 6
Files With Most Units (Top 50)
File# lines# units
AbstractStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/state
 161 21
IdleWindowScaner.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 241 19
WindowState.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 175 17
WindowInfo.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 63 15
StreamContextImpl.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 125 14
GroupedStreamImpl.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 196 14
WindowKey.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 98 14
RocketMQStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/state
 314 13
RStreamImpl.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 102 12
Data.java
in core/src/main/java/org/apache/rocketmq/streams/core/metadata
 52 12
Pipeline.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 70 11
Time.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 41 11
WorkerThread.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 222 10
WindowStreamImpl.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 177 9
JoinedStream.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 136 9
RocketMQUtil.java
in core/src/main/java/org/apache/rocketmq/streams/core/util
 178 9
WindowAccumulatorSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 245 9
WindowAggregateSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 243 9
TopologyBuilder.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology
 73 8
ProcessorNode.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual
 56 8
JoinAggregateSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 117 8
AvgAccumulator.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator
 54 8
AbstractGraphNode.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual
 49 7
Utils.java
in core/src/main/java/org/apache/rocketmq/streams/core/util
 115 7
RocksDBStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/state
 161 7
AbstractProcessor.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 94 6
Pair.java
in core/src/main/java/org/apache/rocketmq/streams/core/util
 31 6
JoinWindowAggregateSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 118 6
SourceSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 55 6
CountAccumulator.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator
 29 6
MinAccumulator.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator
 36 6
Window.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 30 6
MessageQueueListenerWrapper.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 68 5
AggregateSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 68 5
SinkSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 70 5
AddTagSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 32 5
AccumulatorSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 69 5
WindowStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 73 5
RStreamsException.java
in core/src/main/java/org/apache/rocketmq/streams/core/exception
 18 5
RecoverStateStoreThrowable.java
in core/src/main/java/org/apache/rocketmq/streams/core/exception
 17 5
DeserializeThrowable.java
in core/src/main/java/org/apache/rocketmq/streams/core/exception
 18 5
DataProcessThrowable.java
in core/src/main/java/org/apache/rocketmq/streams/core/exception
 17 5
RocketMQClient.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 42 4
StreamBuilder.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 40 4
ValueChangeSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 36 4
FilterSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 30 4
KeySelectSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 28 4
TimestampSelectorSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 30 4
ForeachSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 28 4
MultiValueChangeSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 41 4
Files With Long Lines (Top 34)

There are 34 files with lines longer than 120 characters. In total, there are 135 long lines.

File# lines# units# long lines
WindowAccumulatorSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 245 9 15
WindowAggregateSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 243 9 15
RocketMQUtil.java
in core/src/main/java/org/apache/rocketmq/streams/core/util
 178 9 13
RocketMQStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/state
 314 13 12
IdleWindowScaner.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 241 19 10
JoinWindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 170 4 7
WindowStreamImpl.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 177 9 6
GroupedStreamImpl.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 196 14 6
JoinWindowAggregateSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 118 6 5
WindowStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 73 5 5
WorkerThread.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 222 10 4
JoinedStream.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 136 9 4
AccumulatorSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 69 5 3
RocksDBStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/state
 161 7 3
AggregateWindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 57 2 3
ShuffleProcessorNode.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual
 32 3 2
JoinAggregateSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 117 8 2
StateStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/state
 19 - 2
AggregateSessionWindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 63 2 2
AccumulatorWindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 59 2 2
AbstractProcessor.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 94 6 1
MessageQueueListenerWrapper.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 68 5 1
Pipeline.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 70 11 1
ValueChangeSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 36 4 1
FilterSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 30 4 1
AggregateSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 68 5 1
ForeachSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 28 4 1
MultiValueChangeSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 41 4 1
AbstractStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/state
 161 21 1
WindowState.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 175 17 1
AccumulatorSessionWindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 65 2 1
RecoverStateStoreThrowable.java
in core/src/main/java/org/apache/rocketmq/streams/core/exception
 17 5 1
DeserializeThrowable.java
in core/src/main/java/org/apache/rocketmq/streams/core/exception
 18 5 1
DataProcessThrowable.java
in core/src/main/java/org/apache/rocketmq/streams/core/exception
 17 5 1
Correlations

File Size vs. Commits (all time): 95 points

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

File Size vs. Contributors (all time): 95 points

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

File Size vs. Commits (30 days): 3 points

core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AccumulatorSessionWindowFire.java x: 1 commits (30d) y: 65 lines of code core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AggregateSessionWindowFire.java x: 1 commits (30d) y: 63 lines of code core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java x: 1 commits (30d) y: 241 lines of code
241.0
lines of code
  min: 63.0
  average: 123.0
  25th percentile: 63.0
  median: 65.0
  75th percentile: 241.0
  max: 241.0
0 1.0
commits (30d)
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 1.0

File Size vs. Contributors (30 days): 3 points

core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AccumulatorSessionWindowFire.java x: 1 contributors (30d) y: 65 lines of code core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AggregateSessionWindowFire.java x: 1 contributors (30d) y: 63 lines of code core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java x: 1 contributors (30d) y: 241 lines of code
241.0
lines of code
  min: 63.0
  average: 123.0
  25th percentile: 63.0
  median: 65.0
  75th percentile: 241.0
  max: 241.0
0 1.0
contributors (30d)
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 1.0

File Size vs. Commits (90 days): 14 points

core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AccumulatorSessionWindowFire.java x: 1 commits (90d) y: 65 lines of code core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AggregateSessionWindowFire.java x: 1 commits (90d) y: 63 lines of code core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java x: 2 commits (90d) y: 241 lines of code core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java x: 3 commits (90d) y: 118 lines of code core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java x: 4 commits (90d) y: 245 lines of code core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java x: 3 commits (90d) y: 243 lines of code core/src/main/java/org/apache/rocketmq/streams/core/running/MessageQueueListenerWrapper.java x: 5 commits (90d) y: 68 lines of code core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java x: 6 commits (90d) y: 314 lines of code core/src/main/java/org/apache/rocketmq/streams/core/metadata/StreamConfig.java x: 2 commits (90d) y: 13 lines of code core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java x: 2 commits (90d) y: 222 lines of code core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/MultiValueChangeSupplier.java x: 1 commits (90d) y: 41 lines of code core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ValueChangeSupplier.java x: 1 commits (90d) y: 36 lines of code core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStream.java x: 3 commits (90d) y: 24 lines of code core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java x: 3 commits (90d) y: 196 lines of code
314.0
lines of code
  min: 13.0
  average: 134.93
  25th percentile: 39.75
  median: 93.0
  75th percentile: 241.5
  max: 314.0
0 6.0
commits (90d)
min: 1.0 | average: 2.64 | 25th percentile: 1.0 | median: 2.5 | 75th percentile: 3.25 | max: 6.0

File Size vs. Contributors (90 days): 14 points

core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AccumulatorSessionWindowFire.java x: 1 contributors (90d) y: 65 lines of code core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AggregateSessionWindowFire.java x: 1 contributors (90d) y: 63 lines of code core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java x: 2 contributors (90d) y: 241 lines of code core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java x: 3 contributors (90d) y: 118 lines of code core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java x: 3 contributors (90d) y: 245 lines of code core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java x: 3 contributors (90d) y: 243 lines of code core/src/main/java/org/apache/rocketmq/streams/core/running/MessageQueueListenerWrapper.java x: 3 contributors (90d) y: 68 lines of code core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java x: 3 contributors (90d) y: 314 lines of code core/src/main/java/org/apache/rocketmq/streams/core/metadata/StreamConfig.java x: 2 contributors (90d) y: 13 lines of code core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java x: 2 contributors (90d) y: 222 lines of code core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/MultiValueChangeSupplier.java x: 1 contributors (90d) y: 41 lines of code core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ValueChangeSupplier.java x: 1 contributors (90d) y: 36 lines of code core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStream.java x: 3 contributors (90d) y: 24 lines of code core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java x: 3 contributors (90d) y: 196 lines of code
314.0
lines of code
  min: 13.0
  average: 134.93
  25th percentile: 39.75
  median: 93.0
  75th percentile: 241.5
  max: 314.0
0 3.0
contributors (90d)
min: 1.0 | average: 2.21 | 25th percentile: 1.0 | median: 2.5 | 75th percentile: 3.0 | max: 3.0