Path	Lines of Code
common/src/main/java/org/apache/nemo/common/Pair.java	36
common/src/main/java/org/apache/nemo/common/StateMachine.java	169
common/src/main/java/org/apache/nemo/common/coder/BytesDecoderFactory.java	50
common/src/main/java/org/apache/nemo/common/coder/DecoderFactory.java	28
common/src/main/java/org/apache/nemo/common/ir/IRDAG.java	644
common/src/main/java/org/apache/nemo/common/ir/IRDAGChecker.java	442
common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/AdditionalOutputTagProperty.java	14
common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/CommunicationPatternProperty.java	16
common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/DecoderProperty.java	11
common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/EncoderProperty.java	11
common/src/main/java/org/apache/nemo/common/ir/vertex/LoopVertex.java	245
common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/ClonedSchedulingProperty.java	77
common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/ResourceSiteProperty.java	11
common/src/main/java/org/apache/nemo/common/ir/vertex/utility/TaskSizeSplitterVertex.java	321
common/src/main/java/org/apache/nemo/common/partitioner/DedicatedKeyPerElementPartitioner.java	12
compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/InMemorySideInputReader.java	61
compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/PipelineTranslator.java	398
compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/SideInputElement.java	15
compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/source/BeamBoundedSourceVertex.java	135
compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/source/BeamUnboundedSourceVertex.java	123
compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/AbstractDoFnTransform.java	189
compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/CombineFnFinalTransform.java	60
compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/CombineFnPartialTransform.java	58
compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/PushBackDoFnTransform.java	103
compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/SideInputTransform.java	33
compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/core/SparkFrontendUtils.java	118
compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/transform/GroupByKeyTransform.java	33
compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/transform/LocalTextFileTransform.java	38
compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/transform/ReduceByKeyTransform.java	44
compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/transform/ReduceTransform.java	56
compiler/frontend/spark/src/main/scala/org/apache/nemo/compiler/frontend/spark/core/rdd/RDD.scala	397
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/NemoOptimizer.java	150
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/AggressiveSpeculativeCloningPass.java	17
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultScheduleGroupPass.java	138
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/UpfrontCloningPass.java	26
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/SamplingTaskSizingPass.java	195
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/SkewReshapingPass.java	47
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/BasicPullPolicy.java	23
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/BasicPushPolicy.java	25
runtime/common/src/main/java/org/apache/nemo/runtime/common/RuntimeIdManager.java	59
runtime/common/src/main/java/org/apache/nemo/runtime/common/message/local/LocalMessageContext.java	20
runtime/common/src/main/java/org/apache/nemo/runtime/common/message/ncs/NcsMessageContext.java	34
runtime/common/src/main/java/org/apache/nemo/runtime/common/message/ncs/NcsMessageEnvironment.java	190
runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/MetricUtils.java	306
runtime/driver/src/main/java/org/apache/nemo/driver/NemoDriver.java	207
runtime/driver/src/main/java/org/apache/nemo/driver/RemoteClientMessageLoggingHandler.java	31
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/Executor.java	185
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/BroadcastManagerWorker.java	64
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/MemoryPoolAssigner.java	84
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/partition/SerializedPartition.java	138
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/RunTimeMessageOutputCollector.java	77
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/TaskExecutor.java	533
runtime/master/src/main/java/org/apache/nemo/runtime/master/BlockManagerMaster.java	301
runtime/master/src/main/java/org/apache/nemo/runtime/master/PlanStateManager.java	396
runtime/master/src/main/java/org/apache/nemo/runtime/master/RuntimeMaster.java	346
runtime/master/src/main/java/org/apache/nemo/runtime/master/resource/ContainerManager.java	161
runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/BatchScheduler.java	234
runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/BatchSchedulerUtils.java	238
runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/SimulationScheduler.java	397
runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/StreamingScheduler.java	120
webui/components/jobs/JobsView.vue	726