apache / rocketmq-streamsUnit Size

Intro

Unit size measurements show the distribution of size of units of code (methods, functions...).
Units are classified in four categories based on their size (lines of code): 1-20 (small units), 20-50 (medium size units), 51-100 (long units), 101+ (very long units).
You should aim at keeping units small (< 20 lines). Long units may become "bloaters", code that have increased to such gargantuan proportions that they are hard to work with.

Learn more...

Unit Size Overall

There are 460 units with 3,701 lines of code in units (63.9% of code).

1 very long units (105 lines of code)
2 long units (140 lines of code)
31 medium size units (974 lines of code)
68 small units (945 lines of code)
358 very small units (1,537 lines of code)

Legend:

101+

51-100

21-50

11-20

1-10

Unit Size per Extension

101+

51-100

21-50

11-20

1-10

Unit Size per Logical Component

primary logical decomposition

101+

51-100

21-50

11-20

1-10

Alternative Visuals

3D view of all units

Longest Units

Top 50 longest units

Unit	# lines	McCabe index	# params
public List fire() in core/src/main/java/org/apache/rocketmq/streams/core/window/fire/JoinWindowFire.java	105	23	3
private Pair fireIfSessionOut() in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java	71	15	4
private Pair fireIfSessionOut() in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java	69	15	4
void runInLoop() in core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java	47	9	0
private void doFire() in core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java	47	11	3
public static WindowState byte2WindowState() in core/src/main/java/org/apache/rocketmq/streams/core/window/WindowState.java	44	2	1
public void process() in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java	41	10	1
private void scanAndFireWindow() in core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java	40	10	0
public void process() in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java	39	8	1
private void fire() in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinAggregateSupplier.java	38	10	3
public RStream apply() in core/src/main/java/org/apache/rocketmq/streams/core/rstream/JoinedStream.java	37	2	1
private void replayState() in core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java	35	8	1
public List fire() in core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AccumulatorSessionWindowFire.java	35	4	2
public static void createNormalTopic() in core/src/main/java/org/apache/rocketmq/streams/core/util/RocketMQUtil.java	34	9	4
public List fire() in core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AggregateSessionWindowFire.java	33	4	2
public void loadState() in core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java	32	7	1
public RStream apply() in core/src/main/java/org/apache/rocketmq/streams/core/rstream/JoinedStream.java	31	2	1
public void persist() in core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java	31	9	1
public void removeState() in core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java	31	9	1
public void deleteByKey() in core/src/main/java/org/apache/rocketmq/streams/core/state/AbstractStore.java	30	7	1
public List fire() in core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AccumulatorWindowFire.java	30	4	2
public List fire() in core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AggregateWindowFire.java	28	4	2
public PlanetaryEngine() in core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java	27	3	5
public void process() in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/SinkSupplier.java	27	7	1
private void pullToLast() in core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java	26	7	1
public GroupedStream min() in core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java	25	4	1
public GroupedStream max() in core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java	25	4	1
private static void createStaticTopicWithCommand() in core/src/main/java/org/apache/rocketmq/streams/core/util/RocketMQUtil.java	25	2	5
public void process() in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java	24	4	1
public static void main() in core/src/main/java/org/apache/rocketmq/streams/core/state/RocksDBStore.java	24	2	1
public void process() in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java	23	4	1
public WorkerThread() in core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java	22	1	4
private void createRocksDB() in core/src/main/java/org/apache/rocketmq/streams/core/state/RocksDBStore.java	22	5	1
public void process() in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java	21	4	1
private static boolean check() in core/src/main/java/org/apache/rocketmq/streams/core/util/RocketMQUtil.java	20	5	2
private void store() in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java	20	4	5
public synchronized void start() in core/src/main/java/org/apache/rocketmq/streams/core/RocketMQStream.java	20	4	0
public V byte2Object() in core/src/main/java/org/apache/rocketmq/streams/core/running/AbstractProcessor.java	19	3	1
public void messageQueueChanged() in core/src/main/java/org/apache/rocketmq/streams/core/running/MessageQueueListenerWrapper.java	19	3	3
public void process() in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/AccumulatorSupplier.java	19	3	1
public static void createNormalTopic() in core/src/main/java/org/apache/rocketmq/streams/core/util/RocketMQUtil.java	18	3	3
public Number calculate() in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/SumAggregate.java	18	6	3
public void waitIfNotReady() in core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java	18	3	1
public void forward() in core/src/main/java/org/apache/rocketmq/streams/core/running/StreamContextImpl.java	17	3	1
public synchronized void stop() in core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java	17	3	0
protected long watermark() in core/src/main/java/org/apache/rocketmq/streams/core/running/AbstractWindowProcessor.java	17	3	2
public static void createStaticCompactTopic() in core/src/main/java/org/apache/rocketmq/streams/core/util/RocketMQUtil.java	17	5	4
public void process() in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/AggregateSupplier.java	17	3	1
public void process() in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/PrintSupplier.java	17	3	1
public String whichStateTopicQueueBelongTo() in core/src/main/java/org/apache/rocketmq/streams/core/state/AbstractStore.java	17	7	1