apache / rocketmq-streamsConditional Complexity

Intro

Conditional complexity (also called cyclomatic complexity) is a term used to measure the complexity of software. The term refers to the number of possible paths through a program function. A higher value ofter means higher maintenance and testing costs (infosecinstitute.com).
Conditional complexity is calculated by counting all conditions in the program that can affect the execution path (e.g. if statement, loops, switches, and/or operators, try and catch blocks...).
Conditional complexity is measured at the unit level (methods, functions...).
Units are classified in four categories based on the measured McCabe index: 1-5 (simple units), 6-10 (medium complex units), 11-25 (complex units), 26+ (very complex units).

Learn more...

Conditional Complexity Overall

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

0 very complex units (0 lines of code)
0 complex units (0 lines of code)
4 medium complex units (292 lines of code)
16 simple units (495 lines of code)
440 very simple units (2,914 lines of code)

Legend:

51+

26-50

11-25

6-10

1-5

Alternative Visuals

3D view of all units

Conditional Complexity per Extension

51+

26-50

11-25

6-10

1-5

Conditional Complexity per Logical Component

primary logical decomposition

51+

26-50

11-25

6-10

1-5

Most Complex Units

Top 50 most complex 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
private void doFire() in core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java	47	11	3
private void fire() in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinAggregateSupplier.java	38	10	3
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
void runInLoop() in core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java	47	9	0
public static void createNormalTopic() in core/src/main/java/org/apache/rocketmq/streams/core/util/RocketMQUtil.java	34	9	4
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 process() in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java	39	8	1
private void replayState() in core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java	35	8	1
public void process() in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/SinkSupplier.java	27	7	1
public String whichStateTopicQueueBelongTo() in core/src/main/java/org/apache/rocketmq/streams/core/state/AbstractStore.java	17	7	1
public void deleteByKey() in core/src/main/java/org/apache/rocketmq/streams/core/state/AbstractStore.java	30	7	1
public void loadState() in core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java	32	7	1
private void pullToLast() in core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java	26	7	1
public boolean equals() in core/src/main/java/org/apache/rocketmq/streams/core/window/WindowKey.java	9	7	1
public Number calculate() in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/SumAggregate.java	18	6	3
public static String buildKey() in core/src/main/java/org/apache/rocketmq/streams/core/util/Utils.java	16	5	2
public static String toHexString() in core/src/main/java/org/apache/rocketmq/streams/core/util/Utils.java	16	5	1
public static void createStaticCompactTopic() in core/src/main/java/org/apache/rocketmq/streams/core/util/RocketMQUtil.java	17	5	4
private static boolean check() in core/src/main/java/org/apache/rocketmq/streams/core/util/RocketMQUtil.java	20	5	2
protected Set convertSourceTopicQueue2StateTopicQueue() in core/src/main/java/org/apache/rocketmq/streams/core/state/AbstractStore.java	15	5	1
private void createRocksDB() in core/src/main/java/org/apache/rocketmq/streams/core/state/RocksDBStore.java	22	5	1
private boolean skipWatermarkKey() in core/src/main/java/org/apache/rocketmq/streams/core/state/RocksDBStore.java	11	5	1
void doCommit() in core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java	10	4	1
void createShuffleTopic() in core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java	12	4	0
private void grouping() in core/src/main/java/org/apache/rocketmq/streams/core/topology/TopologyBuilder.java	12	4	2
public boolean equals() in core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual/ProcessorNode.java	6	4	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
public static B byte2Object() in core/src/main/java/org/apache/rocketmq/streams/core/util/Utils.java	6	4	2
public Processor get() in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java	12	4	0
public void process() in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java	24	4	1
public void process() in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java	21	4	1
private void store() in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java	20	4	5
public Processor get() in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java	12	4	0
public void process() in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java	23	4	1
public void process() in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/MultiValueChangeSupplier.java	15	4	1
public long getTimestamp() in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/SourceSupplier.java	11	4	2
public List fire() in core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AggregateWindowFire.java	28	4	2
public List fire() in core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AggregateSessionWindowFire.java	33	4	2
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/AccumulatorSessionWindowFire.java	35	4	2
public void removeOldAccumulatorSession() in core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java	10	4	1
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
protected String toHexString() in core/src/main/java/org/apache/rocketmq/streams/core/running/AbstractProcessor.java	10	3	1