Path	Lines of Code
runtime/common/src/main/java/org/apache/nemo/runtime/common/NativeChannelImplementationSelector.java	39
runtime/common/src/main/java/org/apache/nemo/runtime/common/NettyChannelImplementationSelector.java	12
runtime/common/src/main/java/org/apache/nemo/runtime/common/NioChannelImplementationSelector.java	26
runtime/common/src/main/java/org/apache/nemo/runtime/common/ReplyFutureMap.java	20
runtime/common/src/main/java/org/apache/nemo/runtime/common/RuntimeIdManager.java	59
runtime/common/src/main/java/org/apache/nemo/runtime/common/RuntimeTestUtil.java	19
runtime/common/src/main/java/org/apache/nemo/runtime/common/exception/AbsentBlockException.java	16
runtime/common/src/main/java/org/apache/nemo/runtime/common/exception/PlanAppenderException.java	9
runtime/common/src/main/java/org/apache/nemo/runtime/common/message/ClientRPC.java	110
runtime/common/src/main/java/org/apache/nemo/runtime/common/message/FailedMessageSender.java	17
runtime/common/src/main/java/org/apache/nemo/runtime/common/message/MessageContext.java	4
runtime/common/src/main/java/org/apache/nemo/runtime/common/message/MessageEnvironment.java	17
runtime/common/src/main/java/org/apache/nemo/runtime/common/message/MessageListener.java	5
runtime/common/src/main/java/org/apache/nemo/runtime/common/message/MessageParameters.java	8
runtime/common/src/main/java/org/apache/nemo/runtime/common/message/MessageSender.java	7
runtime/common/src/main/java/org/apache/nemo/runtime/common/message/MessageUtils.java	71
runtime/common/src/main/java/org/apache/nemo/runtime/common/message/PersistentConnectionToMasterMap.java	44
runtime/common/src/main/java/org/apache/nemo/runtime/common/message/grpc/GrpcMessageClient.java	80
runtime/common/src/main/java/org/apache/nemo/runtime/common/message/grpc/GrpcMessageContext.java	21
runtime/common/src/main/java/org/apache/nemo/runtime/common/message/grpc/GrpcMessageEnvironment.java	70
runtime/common/src/main/java/org/apache/nemo/runtime/common/message/grpc/GrpcMessageSender.java	28
runtime/common/src/main/java/org/apache/nemo/runtime/common/message/grpc/GrpcMessageServer.java	106
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/local/LocalMessageDispatcher.java	73
runtime/common/src/main/java/org/apache/nemo/runtime/common/message/local/LocalMessageEnvironment.java	54
runtime/common/src/main/java/org/apache/nemo/runtime/common/message/local/LocalMessageSender.java	38
runtime/common/src/main/java/org/apache/nemo/runtime/common/message/ncs/ControlMessageCodec.java	21
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/message/ncs/NcsMessageSender.java	33
runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/DataTransferEvent.java	20
runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/Event.java	14
runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/JobMetric.java	108
runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/LatencyMetric.java	22
runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/Metric.java	5
runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/MetricUtils.java	306
runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/StageMetric.java	31
runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/StateMetric.java	7
runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/StateTransitionEvent.java	17
runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/StreamMetric.java	35
runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/TaskMetric.java	239
runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/PhysicalPlan.java	35
runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/PhysicalPlanGenerator.java	196
runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/PlanRewriter.java	6
runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/RuntimeEdge.java	43
runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/Stage.java	83
runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/StageEdge.java	100
runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/StagePartitioner.java	63
runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/Task.java	81
runtime/common/src/main/java/org/apache/nemo/runtime/common/state/BlockState.java	32
runtime/common/src/main/java/org/apache/nemo/runtime/common/state/PlanState.java	36
runtime/common/src/main/java/org/apache/nemo/runtime/common/state/StageState.java	33
runtime/common/src/main/java/org/apache/nemo/runtime/common/state/TaskState.java	49
runtime/common/src/main/proto/ControlMessage.proto	222
runtime/common/src/main/proto/GrcpMessageService.proto	32
runtime/driver/src/main/java/org/apache/nemo/driver/NemoContext.java	56
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/driver/src/main/java/org/apache/nemo/driver/UserApplicationRunner.java	71
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/Executor.java	185
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/MetricManagerWorker.java	77
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/MetricMessageSender.java	8
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/TaskStateManager.java	86
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/TransformContextImpl.java	25
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/BlockManagerWorker.java	366
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/BlockTransferThrottler.java	44
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/DataUtil.java	296
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/DirectByteBufferOutputStream.java	99
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/FileArea.java	45
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/LimitedInputStream.java	20
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/MemoryAllocationException.java	6
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/MemoryChunk.java	272
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/PipeContainer.java	91
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/PipeManagerWorker.java	135
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/SerializerManager.java	54
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/block/Block.java	18
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/block/FileBlock.java	248
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/block/NonSerializedMemoryBlock.java	121
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/block/SerializedMemoryBlock.java	144
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/metadata/FileMetadata.java	43
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/metadata/LocalFileMetadata.java	16
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/metadata/PartitionMetadata.java	34
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/metadata/RemoteFileMetadata.java	70
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/partition/NonSerializedPartition.java	69
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/partition/Partition.java	9
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/data/stores/AbstractBlockStore.java	21
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/stores/BlockStore.java	11
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/stores/GlusterFileStore.java	85
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/stores/LocalBlockStore.java	23
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/stores/LocalFileStore.java	60
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/stores/MemoryStore.java	38
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/stores/RemoteFileStore.java	5
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/stores/SerializedMemoryStore.java	39
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/streamchainer/CompressionStreamChainer.java	26
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/streamchainer/DecodeStreamChainer.java	6
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/streamchainer/DecompressionStreamChainer.java	26
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/streamchainer/EncodeStreamChainer.java	6
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/streamchainer/Serializer.java	31
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/BlockInputReader.java	142
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/BlockOutputWriter.java	100
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/DataFetcherOutputCollector.java	36
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/InputReader.java	18
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/InputWatermarkManager.java	5
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/IntermediateDataIOFactory.java	46
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/MultiInputWatermarkManager.java	64
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/NemoEventDecoderFactory.java	61
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/NemoEventEncoderFactory.java	48
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/NextIntraTaskOperatorInfo.java	23
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/OperatorVertexOutputCollector.java	102
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/OperatorWatermarkCollector.java	30
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/OutputWriter.java	11
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/PipeInputReader.java	65
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/PipeOutputWriter.java	108
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/RunTimeMessageOutputCollector.java	77
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/SingleInputWatermarkManager.java	17
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/WatermarkWithIndex.java	25
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/DataFetcher.java	20
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/MultiThreadParentTaskDataFetcher.java	158
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/ParentTaskDataFetcher.java	158
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/SourceVertexDataFetcher.java	83
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/TaskExecutor.java	533
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/VertexHarness.java	46
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteInputContext.java	181
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteOutputContext.java	151
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteTransfer.java	72
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteTransferContext.java	128
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteTransport.java	185
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteTransportChannelInitializer.java	44
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ClosableBlockingQueue.java	56
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ContextManager.java	160
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ControlFrameEncoder.java	48
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/DataFrameEncoder.java	87
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/FrameDecoder.java	140
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/LocalInputContext.java	56
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/LocalOutputContext.java	49
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/LocalTransferContext.java	31
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/OutputContext.java	6
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/TransferOutputStream.java	7
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/package-info.java	1
runtime/master/src/main/java/org/apache/nemo/runtime/master/BlockManagerMaster.java	301
runtime/master/src/main/java/org/apache/nemo/runtime/master/BlockMetadata.java	76
runtime/master/src/main/java/org/apache/nemo/runtime/master/BroadcastManagerMaster.java	19
runtime/master/src/main/java/org/apache/nemo/runtime/master/PipeManagerMaster.java	111
runtime/master/src/main/java/org/apache/nemo/runtime/master/PlanAppender.java	80
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/metric/MetricBroadcaster.java	49
runtime/master/src/main/java/org/apache/nemo/runtime/master/metric/MetricManagerMaster.java	52
runtime/master/src/main/java/org/apache/nemo/runtime/master/metric/MetricMessageHandler.java	8
runtime/master/src/main/java/org/apache/nemo/runtime/master/metric/MetricStore.java	229
runtime/master/src/main/java/org/apache/nemo/runtime/master/resource/ContainerManager.java	161
runtime/master/src/main/java/org/apache/nemo/runtime/master/resource/DefaultExecutorRepresenter.java	158
runtime/master/src/main/java/org/apache/nemo/runtime/master/resource/ExecutorRepresenter.java	19
runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/AntiAffinitySchedulingConstraint.java	34
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/ContainerTypeAwareSchedulingConstraint.java	19
runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/ExecutorRegistry.java	84
runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/FreeSlotSchedulingConstraint.java	19
runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/LocalitySchedulingConstraint.java	89
runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/MinOccupancyFirstSchedulingPolicy.java	29
runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/NodeShareSchedulingConstraint.java	45
runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/PendingTaskCollectionPointer.java	29
runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/Scheduler.java	21
runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/SchedulingConstraint.java	11
runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/SchedulingConstraintRegistry.java	44
runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/SchedulingPolicy.java	14
runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/SimulatedTaskExecutor.java	147
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
runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/TaskDispatcher.java	155
runtime/master/src/main/java/org/apache/nemo/runtime/master/servlet/AllMetricServlet.java	16
runtime/master/src/main/java/org/apache/nemo/runtime/master/servlet/JobMetricServlet.java	17
runtime/master/src/main/java/org/apache/nemo/runtime/master/servlet/StageMetricServlet.java	17
runtime/master/src/main/java/org/apache/nemo/runtime/master/servlet/TaskMetricServlet.java	17
runtime/master/src/main/java/org/apache/nemo/runtime/master/servlet/WebSocketMetricAdapter.java	36
runtime/master/src/main/java/org/apache/nemo/runtime/master/servlet/WebSocketMetricServlet.java	9