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

2 very long units (302 lines of code)
22 long units (1,423 lines of code)
150 medium size units (4,526 lines of code)
304 small units (4,351 lines of code)
1,993 very small units (8,644 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
override def persist() in compiler/frontend/spark/src/main/scala/org/apache/nemo/compiler/frontend/spark/core/rdd/RDD.scala	188	2	0
public TaskSizeSplitterVertex unRollIteration() in common/src/main/java/org/apache/nemo/common/ir/vertex/utility/TaskSizeSplitterVertex.java	114	16	1
public DAG stagePartitionIrDAG() in runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/PhysicalPlanGenerator.java	87	17	1
private ByteTransport() in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteTransport.java	86	12	2
public void insert() in common/src/main/java/org/apache/nemo/common/ir/IRDAG.java	75	10	6
public IRDAG apply() in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/LoopOptimizations.java	73	9	1
public final boolean processMetricMessage() in runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/TaskMetric.java	71	21	2
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/SamplingTaskSizingPass.java	69	15	1
public IRDAG apply() in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/CommonSubexpressionEliminationPass.java	69	11	1
private boolean handleDataFetchers() in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/TaskExecutor.java	67	16	1
void addParallelismCheckers() in common/src/main/java/org/apache/nemo/common/ir/IRDAGChecker.java	67	19	0
Pair analyzeMessage() in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/runtime/SkewRunTimePass.java	66	11	4
private void deleteRecursively() in common/src/main/java/org/apache/nemo/common/ir/IRDAG.java	64	9	2
public CompletableFuture readBlock() in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/BlockManagerWorker.java	62	8	4
public synchronized void onTaskStateChanged() in runtime/master/src/main/java/org/apache/nemo/runtime/master/PlanStateManager.java	57	14	2
public static PhysicalPlan appendPlan() in runtime/master/src/main/java/org/apache/nemo/runtime/master/PlanAppender.java	57	3	2
override def persist() in compiler/frontend/spark/src/main/scala/org/apache/nemo/compiler/frontend/spark/core/rdd/RDD.scala	57	11	1
public IRDAG apply() in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultScheduleGroupPass.java	57	2	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
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 DAG groupLoops() in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/LoopExtractionPass.java	51	12	2
public CompletableFuture read() in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/PipeManagerWorker.java	50	4	3
public void insert() in common/src/main/java/org/apache/nemo/common/ir/IRDAG.java	50	8	2
DAG recursivelyOptimize() in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/LoopOptimizations.java	49	3	1
public void insert() in common/src/main/java/org/apache/nemo/common/ir/IRDAG.java	48	3	2
public IRDAG apply() in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/XGBoostPass.java	48	9	1
private RuntimeMaster() in runtime/master/src/main/java/org/apache/nemo/runtime/master/RuntimeMaster.java	46	1	9
void addScheduleGroupCheckers() in common/src/main/java/org/apache/nemo/common/ir/IRDAGChecker.java	46	10	0
private boolean onControlBodyAdded() in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/FrameDecoder.java	45	5	2
public DAGBuilder connectSplitterVertexWithReplacing() in common/src/main/java/org/apache/nemo/common/dag/DAGBuilder.java	45	12	2
private static void assignNodeShares() in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/ResourceSitePass.java	45	9	2
private void handleControlMessage() in runtime/master/src/main/java/org/apache/nemo/runtime/master/RuntimeMaster.java	44	7	1
private void launchTask() in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/Executor.java	44	2	1
public void onOutputContext() in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/BlockManagerWorker.java	44	8	1
private DAGBuilder rebuildExcludingSplitter() in common/src/main/java/org/apache/nemo/common/ir/IRDAG.java	44	9	2
public PhysicalPlan rewrite() in compiler/backend/src/main/java/org/apache/nemo/compiler/backend/nemo/NemoPlanRewriter.java	44	7	1
public void send() in runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/SimulationScheduler.java	43	8	1
private void saveOptimizationMetrics() in runtime/master/src/main/java/org/apache/nemo/runtime/master/metric/MetricStore.java	43	4	3
private static AbstractDoFnTransform createDoFnTransform() in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/PipelineTranslator.java	43	3	3
void addEncodingCompressionCheckers() in common/src/main/java/org/apache/nemo/common/ir/IRDAGChecker.java	42	11	0
public IRDAG apply() in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/SamplingSkewReshapingPass.java	42	4	1
private BlockManagerWorker() in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/BlockManagerWorker.java	41	1	1
public static void setup() in client/src/main/java/org/apache/nemo/client/JobLauncher.java	41	4	1
public static void launchDAG() in client/src/main/java/org/apache/nemo/client/JobLauncher.java	41	6	3
private NemoDriver() in runtime/driver/src/main/java/org/apache/nemo/driver/NemoDriver.java	40	1	8
public LoopVertex unRollIteration() in common/src/main/java/org/apache/nemo/common/ir/vertex/LoopVertex.java	40	2	1
private void doScheduleTaskList() in runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/TaskDispatcher.java	39	8	0