apache / incubator-nemoConditional 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 2,471 units with 19,246 lines of code in units (59.0% of code).

0 very complex units (0 lines of code)
0 complex units (0 lines of code)
24 medium complex units (1,380 lines of code)
65 simple units (2,031 lines of code)
2,382 very simple units (15,835 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 final boolean processMetricMessage() in runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/TaskMetric.java	71	21	2
void addParallelismCheckers() in common/src/main/java/org/apache/nemo/common/ir/IRDAGChecker.java	67	19	0
public DAG stagePartitionIrDAG() in runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/PhysicalPlanGenerator.java	87	17	1
private MessageType getMsgType() in runtime/common/src/main/java/org/apache/nemo/runtime/common/message/ncs/NcsMessageEnvironment.java	25	17	1
private boolean handleDataFetchers() in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/TaskExecutor.java	67	16	1
public TaskSizeSplitterVertex unRollIteration() in common/src/main/java/org/apache/nemo/common/ir/vertex/utility/TaskSizeSplitterVertex.java	114	16	1
public synchronized void onTaskStateReportFromExecutor() in runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/SimulationScheduler.java	55	15	6
public void onTaskStateReportFromExecutor() in runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/BatchScheduler.java	55	15	6
def dict_union() in ml/nemo_xgboost_optimization.py	23	15	2
public IRDAG apply() in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/SamplingTaskSizingPass.java	69	15	1
private static Boolean checkAnnotatingPass() in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/PolicyImpl.java	30	15	2
public synchronized void onTaskStateChanged() in runtime/master/src/main/java/org/apache/nemo/runtime/master/PlanStateManager.java	57	14	2
static Serializable indexToValue() in runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/MetricUtils.java	54	13	3
public void insert() in common/src/main/java/org/apache/nemo/common/ir/IRDAG.java	54	13	1
private ByteTransport() in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteTransport.java	86	12	2
public DAGBuilder connectSplitterVertexWithReplacing() in common/src/main/java/org/apache/nemo/common/dag/DAGBuilder.java	45	12	2
public DAGBuilder connectSplitterVertexWithoutReplacing() in common/src/main/java/org/apache/nemo/common/dag/DAGBuilder.java	33	12	2
private DAG groupLoops() in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/LoopExtractionPass.java	51	12	2
public CheckerResult doCheck() in common/src/main/java/org/apache/nemo/common/ir/IRDAGChecker.java	33	11	1
void addEncodingCompressionCheckers() in common/src/main/java/org/apache/nemo/common/ir/IRDAGChecker.java	42	11	0
override def persist() in compiler/frontend/spark/src/main/scala/org/apache/nemo/compiler/frontend/spark/core/rdd/RDD.scala	57	11	1
Pair analyzeMessage() in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/runtime/SkewRunTimePass.java	66	11	4
private DAG loopRolling() in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/LoopExtractionPass.java	70	11	1
public IRDAG apply() in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/CommonSubexpressionEliminationPass.java	69	11	1
public synchronized List getTaskAttemptsToSchedule() in runtime/master/src/main/java/org/apache/nemo/runtime/master/PlanStateManager.java	36	10	1
public void insert() in common/src/main/java/org/apache/nemo/common/ir/IRDAG.java	75	10	6
void addScheduleGroupCheckers() in common/src/main/java/org/apache/nemo/common/ir/IRDAGChecker.java	46	10	0
static Integer valueToIndex() in runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/MetricUtils.java	32	9	2
private void onEventFromDataFetcher() in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/TaskExecutor.java	33	9	2
private void deleteRecursively() in common/src/main/java/org/apache/nemo/common/ir/IRDAG.java	64	9	2
private DAGBuilder rebuildExcludingSplitter() in common/src/main/java/org/apache/nemo/common/ir/IRDAG.java	44	9	2
void addShuffleEdgeCheckers() in common/src/main/java/org/apache/nemo/common/ir/IRDAGChecker.java	27	9	0
public IRDAG apply() in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/LoopOptimizations.java	73	9	1
public IRDAG apply() in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/XGBoostPass.java	48	9	1
private static void assignNodeShares() in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/ResourceSitePass.java	45	9	2
private static void updateMetaData() in runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/MetricUtils.java	37	8	0
private void doScheduleTaskList() in runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/TaskDispatcher.java	39	8	0
public void send() in runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/SimulationScheduler.java	43	8	1
public int read() in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteInputContext.java	30	8	3
private boolean onFrameStarted() in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/FrameDecoder.java	36	8	2
public void emitWatermark() in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/OperatorVertexOutputCollector.java	21	8	1
public void emitLatencymark() in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/OperatorVertexOutputCollector.java	21	8	1
public CompletableFuture readBlock() in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/BlockManagerWorker.java	62	8	4
public void onOutputContext() in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/BlockManagerWorker.java	44	8	1
public boolean hasNext() in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/DataUtil.java	36	8	0
private Set getVertexGroupToDelete() in common/src/main/java/org/apache/nemo/common/ir/IRDAG.java	20	8	1
public void insert() in common/src/main/java/org/apache/nemo/common/ir/IRDAG.java	50	8	2
void addPartitioningCheckers() in common/src/main/java/org/apache/nemo/common/ir/IRDAGChecker.java	31	8	0
private PipelineTranslator() in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/PipelineTranslator.java	24	8	0
public IRDAG apply() in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultParallelismPass.java	36	8	1