path	# lines of code
tools/network_profiling/network_clustering.py	22
tools/network_profiling/network_profiling.py	79
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/driver/src/main/java/org/apache/nemo/driver/NemoContext.java	56
runtime/driver/src/main/java/org/apache/nemo/driver/NemoDriver.java	207
runtime/common/src/main/proto/GrcpMessageService.proto	32
runtime/common/src/main/proto/ControlMessage.proto	222
runtime/common/src/main/java/org/apache/nemo/runtime/common/NativeChannelImplementationSelector.java	39
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/PlanRewriter.java	6
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/PhysicalPlan.java	35
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/plan/StageEdge.java	100
runtime/common/src/main/java/org/apache/nemo/runtime/common/RuntimeTestUtil.java	19
runtime/common/src/main/java/org/apache/nemo/runtime/common/RuntimeIdManager.java	59
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/MessageContext.java	4
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/GrpcMessageEnvironment.java	70
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/grpc/GrpcMessageContext.java	21
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/MessageParameters.java	8
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/MessageEnvironment.java	17
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/LocalMessageSender.java	38
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/MessageUtils.java	71
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/NcsMessageSender.java	33
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/MessageSender.java	7
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/PersistentConnectionToMasterMap.java	44
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/TaskState.java	49
runtime/common/src/main/java/org/apache/nemo/runtime/common/state/StageState.java	33
runtime/common/src/main/java/org/apache/nemo/runtime/common/ReplyFutureMap.java	20
runtime/common/src/main/java/org/apache/nemo/runtime/common/NettyChannelImplementationSelector.java	12
runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/TaskMetric.java	239
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/DataTransferEvent.java	20
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/Event.java	14
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/StreamMetric.java	35
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/MetricUtils.java	306
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/NioChannelImplementationSelector.java	26
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/WebSocketMetricServlet.java	9
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/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/BlockMetadata.java	76
runtime/master/src/main/java/org/apache/nemo/runtime/master/PlanStateManager.java	396
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/scheduler/ContainerTypeAwareSchedulingConstraint.java	19
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/SimulationScheduler.java	397
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/BatchScheduler.java	234
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/NodeShareSchedulingConstraint.java	45
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/SimulatedTaskExecutor.java	147
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/LocalitySchedulingConstraint.java	89
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/BatchSchedulerUtils.java	238
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/SchedulingPolicy.java	14
runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/ExecutorRegistry.java	84
runtime/master/src/main/java/org/apache/nemo/runtime/master/PipeManagerMaster.java	111
runtime/master/src/main/java/org/apache/nemo/runtime/master/BroadcastManagerMaster.java	19
runtime/master/src/main/java/org/apache/nemo/runtime/master/BlockManagerMaster.java	301
runtime/master/src/main/java/org/apache/nemo/runtime/master/PlanAppender.java	80
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/resource/ContainerManager.java	161
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/MetricStore.java	229
runtime/master/src/main/java/org/apache/nemo/runtime/master/metric/MetricMessageHandler.java	8
runtime/master/src/main/java/org/apache/nemo/runtime/master/RuntimeMaster.java	346
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/TransformContextImpl.java	25
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/TransferOutputStream.java	7
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/DataFrameEncoder.java	87
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/LocalOutputContext.java	49
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/ClosableBlockingQueue.java	56
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/LocalInputContext.java	56
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/ByteOutputContext.java	151
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/ByteTransportChannelInitializer.java	44
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/package-info.java	1
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/FrameDecoder.java	140
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/DataFetcherOutputCollector.java	36
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/SingleInputWatermarkManager.java	17
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/NemoEventEncoderFactory.java	48
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/WatermarkWithIndex.java	25
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/PipeOutputWriter.java	108
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/RunTimeMessageOutputCollector.java	77
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/OperatorVertexOutputCollector.java	102
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/MultiInputWatermarkManager.java	64
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/BlockOutputWriter.java	100
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/MetricMessageSender.java	8
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/MetricManagerWorker.java	77
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/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/task/DataFetcher.java	20
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/Executor.java	185
runtime/executor/src/main/java/org/apache/nemo/runtime/executor/TaskStateManager.java	86
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/BlockManagerWorker.java	366
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/MemoryPoolAssigner.java	84
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/CompressionStreamChainer.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/DecodeStreamChainer.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/data/MemoryAllocationException.java	6
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/BlockTransferThrottler.java	44
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/LocalBlockStore.java	23
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/LocalFileStore.java	60
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/GlusterFileStore.java	85
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/MemoryChunk.java	272
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/SerializerManager.java	54
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/NonSerializedPartition.java	69
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/PipeManagerWorker.java	135
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/metadata/RemoteFileMetadata.java	70
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/FileMetadata.java	43
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/block/FileBlock.java	248
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/DirectByteBufferOutputStream.java	99
formatter.xml	397
common/src/main/java/org/apache/nemo/common/KeyExtractor.java	5
common/src/main/java/org/apache/nemo/common/HashRange.java	62
common/src/main/java/org/apache/nemo/common/Util.java	171
common/src/main/java/org/apache/nemo/common/Pair.java	36
common/src/main/java/org/apache/nemo/common/pass/Pass.java	19
common/src/main/java/org/apache/nemo/common/partitioner/DedicatedKeyPerElementPartitioner.java	12
common/src/main/java/org/apache/nemo/common/partitioner/DedicatedKeyPerElement.java	7
common/src/main/java/org/apache/nemo/common/partitioner/Partitioner.java	43
common/src/main/java/org/apache/nemo/common/partitioner/IntactPartitioner.java	7
common/src/main/java/org/apache/nemo/common/partitioner/HashPartitioner.java	15
common/src/main/java/org/apache/nemo/common/ir/IdManager.java	50
common/src/main/java/org/apache/nemo/common/ir/IRDAG.java	644
common/src/main/java/org/apache/nemo/common/ir/BoundedIteratorReadable.java	18
common/src/main/java/org/apache/nemo/common/ir/executionproperty/ExecutionProperty.java	35
common/src/main/java/org/apache/nemo/common/ir/executionproperty/ResourceSpecification.java	47
common/src/main/java/org/apache/nemo/common/ir/executionproperty/EdgeExecutionProperty.java	7
common/src/main/java/org/apache/nemo/common/ir/executionproperty/VertexExecutionProperty.java	7
common/src/main/java/org/apache/nemo/common/ir/executionproperty/ExecutionPropertyMap.java	126
common/src/main/java/org/apache/nemo/common/ir/executionproperty/AssociatedProperty.java	8
common/src/main/java/org/apache/nemo/common/ir/edge/IREdge.java	69
common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/DuplicateEdgeGroupProperty.java	10
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/EncoderProperty.java	11
common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/DataFlowProperty.java	14
common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/KeyEncoderProperty.java	11
common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/CompressionProperty.java	15
common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/DuplicateEdgeGroupPropertyValue.java	49
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/PartitionerProperty.java	30
common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/KeyExtractorProperty.java	11
common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/DataStoreProperty.java	17
common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/MessageIdEdgeProperty.java	11
common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/KeyDecoderProperty.java	11
common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/DecompressionProperty.java	10
common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/PartitionSetProperty.java	12
common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/DataPersistenceProperty.java	14
common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/BlockFetchFailureProperty.java	14
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/CacheIDProperty.java	11
common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/SubPartitionSetProperty.java	12
common/src/main/java/org/apache/nemo/common/ir/Readable.java	12
common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/MessageIdVertexProperty.java	10
common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/ResourceAntiAffinityProperty.java	11
common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/ParallelismProperty.java	10
common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/EnableDynamicTaskSizingProperty.java	10
common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/ScheduleGroupProperty.java	10
common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/ResourcePriorityProperty.java	14
common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/ResourceSiteProperty.java	11
common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/ResourceLambdaProperty.java	14
common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/ResourceSlotProperty.java	13
common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/ResourceLocalityProperty.java	12
common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/IgnoreSchedulingTempDataReceiverProperty.java	15
common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/ClonedSchedulingProperty.java	77
common/src/main/java/org/apache/nemo/common/ir/vertex/SourceVertex.java	15
common/src/main/java/org/apache/nemo/common/ir/vertex/CachedSourceVertex.java	66
common/src/main/java/org/apache/nemo/common/ir/vertex/LoopVertex.java	245
common/src/main/java/org/apache/nemo/common/ir/vertex/InMemorySourceVertex.java	76
common/src/main/java/org/apache/nemo/common/ir/vertex/IRVertex.java	50
common/src/main/java/org/apache/nemo/common/ir/vertex/transform/Transform.java	18
common/src/main/java/org/apache/nemo/common/ir/vertex/transform/StreamTransform.java	28
common/src/main/java/org/apache/nemo/common/ir/vertex/transform/SignalTransform.java	29
common/src/main/java/org/apache/nemo/common/ir/vertex/transform/LatencymarkEmitTransform.java	17
common/src/main/java/org/apache/nemo/common/ir/vertex/transform/MessageAggregatorTransform.java	39
common/src/main/java/org/apache/nemo/common/ir/vertex/transform/NoWatermarkEmitTransform.java	11
common/src/main/java/org/apache/nemo/common/ir/vertex/transform/MessageGeneratorTransform.java	41
common/src/main/java/org/apache/nemo/common/ir/vertex/OperatorVertex.java	27
common/src/main/java/org/apache/nemo/common/ir/vertex/utility/SamplingVertex.java	67
common/src/main/java/org/apache/nemo/common/ir/vertex/utility/runtimepass/MessageAggregatorVertex.java	25
common/src/main/java/org/apache/nemo/common/ir/vertex/utility/runtimepass/MessageGeneratorVertex.java	18
common/src/main/java/org/apache/nemo/common/ir/vertex/utility/runtimepass/SignalVertex.java	13
common/src/main/java/org/apache/nemo/common/ir/vertex/utility/TaskSizeSplitterVertex.java	321
common/src/main/java/org/apache/nemo/common/ir/vertex/utility/RelayVertex.java	8
common/src/main/java/org/apache/nemo/common/ir/IRDAGChecker.java	442
common/src/main/java/org/apache/nemo/common/ir/OutputCollector.java	10
common/src/main/java/org/apache/nemo/common/dag/DAGInterface.java	42
common/src/main/java/org/apache/nemo/common/dag/DAG.java	247
common/src/main/java/org/apache/nemo/common/dag/DAGBuilder.java	269
common/src/main/java/org/apache/nemo/common/dag/Vertex.java	20
common/src/main/java/org/apache/nemo/common/dag/Edge.java	33
common/src/main/java/org/apache/nemo/common/KeyRange.java	14
common/src/main/java/org/apache/nemo/common/StateMachine.java	169
common/src/main/java/org/apache/nemo/common/Cloneable.java	4
common/src/main/java/org/apache/nemo/common/punctuation/Watermark.java	35
common/src/main/java/org/apache/nemo/common/punctuation/LatencyMark.java	54
common/src/main/java/org/apache/nemo/common/punctuation/Finishmark.java	9
common/src/main/java/org/apache/nemo/common/coder/BytesEncoderFactory.java	29
common/src/main/java/org/apache/nemo/common/coder/DecoderFactory.java	28
common/src/main/java/org/apache/nemo/common/coder/EncoderFactory.java	28
common/src/main/java/org/apache/nemo/common/coder/BytesDecoderFactory.java	50
common/src/main/java/org/apache/nemo/common/coder/LongEncoderFactory.java	30
common/src/main/java/org/apache/nemo/common/coder/LongDecoderFactory.java	30
common/src/main/java/org/apache/nemo/common/coder/PairDecoderFactory.java	49
common/src/main/java/org/apache/nemo/common/coder/IntEncoderFactory.java	30
common/src/main/java/org/apache/nemo/common/coder/PairEncoderFactory.java	51
common/src/main/java/org/apache/nemo/common/coder/IntDecoderFactory.java	30
common/src/main/java/org/apache/nemo/common/eventhandler/CommonEventHandler.java	5
common/src/main/java/org/apache/nemo/common/eventhandler/CompilerEvent.java	3
common/src/main/java/org/apache/nemo/common/eventhandler/RuntimeEvent.java	3
common/src/main/java/org/apache/nemo/common/eventhandler/RuntimeEventHandler.java	3
common/src/main/java/org/apache/nemo/common/eventhandler/PubSubEventHandlerWrapper.java	13
common/src/main/java/org/apache/nemo/common/eventhandler/CompilerEventHandler.java	3
common/src/main/java/org/apache/nemo/common/exception/MetricException.java	9
common/src/main/java/org/apache/nemo/common/exception/UnsupportedMethodException.java	6
common/src/main/java/org/apache/nemo/common/exception/BlockWriteException.java	6
common/src/main/java/org/apache/nemo/common/exception/UnsupportedMetricException.java	6
common/src/main/java/org/apache/nemo/common/exception/IllegalEdgeOperationException.java	9
common/src/main/java/org/apache/nemo/common/exception/DataSourceException.java	6
common/src/main/java/org/apache/nemo/common/exception/InvalidParameterException.java	6
common/src/main/java/org/apache/nemo/common/exception/RuntimeOptimizationException.java	9
common/src/main/java/org/apache/nemo/common/exception/SimulationException.java	9
common/src/main/java/org/apache/nemo/common/exception/UnsupportedExecutionPropertyException.java	6
common/src/main/java/org/apache/nemo/common/exception/UnsupportedCommPatternException.java	6
common/src/main/java/org/apache/nemo/common/exception/UnknownExecutionStateException.java	6
common/src/main/java/org/apache/nemo/common/exception/SchedulingException.java	6
common/src/main/java/org/apache/nemo/common/exception/UnsupportedBlockStoreException.java	6
common/src/main/java/org/apache/nemo/common/exception/IllegalMessageException.java	6
common/src/main/java/org/apache/nemo/common/exception/BlockFetchException.java	6
common/src/main/java/org/apache/nemo/common/exception/UnsupportedPartitionerException.java	6
common/src/main/java/org/apache/nemo/common/exception/IllegalStateTransitionException.java	6
common/src/main/java/org/apache/nemo/common/exception/ContainerException.java	6
common/src/main/java/org/apache/nemo/common/exception/InvalidUserMainException.java	9
common/src/main/java/org/apache/nemo/common/exception/UnsupportedCompressionException.java	6
common/src/main/java/org/apache/nemo/common/exception/UnrecoverableFailureException.java	6
common/src/main/java/org/apache/nemo/common/exception/DynamicOptimizationException.java	9
common/src/main/java/org/apache/nemo/common/exception/CompileTimeOptimizationException.java	9
common/src/main/java/org/apache/nemo/common/exception/PhysicalPlanGenerationException.java	9
common/src/main/java/org/apache/nemo/common/exception/IllegalVertexOperationException.java	6
common/src/main/java/org/apache/nemo/common/exception/JsonParseException.java	6
common/src/main/java/org/apache/nemo/common/exception/OutputMismatchException.java	9
common/src/main/java/org/apache/nemo/common/exception/UnknownFailureCauseException.java	6
common/src/main/java/org/apache/nemo/common/exception/NodeConnectionException.java	6
common/src/main/java/org/apache/nemo/common/PairKeyExtractor.java	23
common/src/main/java/org/apache/nemo/common/ByteBufferInputStream.java	28
ml/nemo_xgboost_optimization.py	264
webui/nuxt.config.js	39
webui/plugins/vue2vis.js	3
webui/plugins/vue-affix.js	3
webui/plugins/element-ui.js	4
webui/plugins/event-bus.js	6
webui/components/stages/StagesView.vue	142
webui/components/MainContainer.vue	91
webui/components/storage/StorageView.vue	31
webui/components/executors/ExecutorsView.vue	32
webui/components/environment/EnvironmentView.vue	32
webui/components/jobs/JobsView.vue	726
webui/components/jobs/detail/StageSelect.vue	172
webui/components/jobs/detail/MetricTimeline.vue	126
webui/components/jobs/detail/JobView.vue	272
webui/components/jobs/detail/DetailTable.vue	49
webui/components/jobs/detail/DAG.vue	662
webui/components/TaskStatistics.vue	91
webui/layouts/default.vue	34
webui/assets/constants.js	16
webui/pages/index.vue	13
conf/src/main/java/org/apache/nemo/conf/DataPlaneConf.java	49
conf/src/main/java/org/apache/nemo/conf/JobConf.java	161
client/src/main/java/org/apache/nemo/client/NemoClient.java	21
client/src/main/java/org/apache/nemo/client/DriverEndpoint.java	24
client/src/main/java/org/apache/nemo/client/ClientUtils.java	56
client/src/main/java/org/apache/nemo/client/ClientEndpoint.java	76
client/src/main/java/org/apache/nemo/client/StateTranslator.java	5
client/src/main/java/org/apache/nemo/client/beam/NemoRunnerRegistrar.java	26
client/src/main/java/org/apache/nemo/client/beam/NemoRunner.java	37
client/src/main/java/org/apache/nemo/client/beam/NemoPipelineResult.java	65
client/src/main/java/org/apache/nemo/client/beam/BeamStateTranslator.java	21
client/src/main/java/org/apache/nemo/client/DriverRPCServer.java	120
client/src/main/java/org/apache/nemo/client/JobLauncher.java	339
client/src/main/java/org/apache/reef/runtime/yarn/ClassPathBuilder.java	46
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/InMemorySideInputReader.java	61
compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/PipelineVisitor.java	28
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/PipelineTranslator.java	398
compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/BeamKeyExtractor.java	28
compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/NemoPipelineOptions.java	14
compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/PipelineTranslationContext.java	188
compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/coder/BeamEncoderFactory.java	55
compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/coder/SideInputCoder.java	37
compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/coder/BeamDecoderFactory.java	74
compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/SideInputTransform.java	33
compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/DoFnTransform.java	56
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/DefaultOutputManager.java	22
compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/GBKTransform.java	212
compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/FlattenTransform.java	25
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/LoopCompositeTransform.java	8
compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/PartialCombineFn.java	38
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/WindowFnTransform.java	61
compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/CreateViewTransform.java	81
compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/InMemoryTimerInternalsFactory.java	49
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/GroupByKeyTransform.java	40
compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/InMemoryStateInternalsFactory.java	23
compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/FinalCombineFn.java	39
compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/core/JavaSparkContext.java	22
compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/core/SparkContext.java	35
compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/core/rdd/SparkJavaRDD.java	423
compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/core/rdd/SparkJavaPairRDD.java	511
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/core/SparkBroadcast.java	22
compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/source/SparkDatasetBoundedSourceVertex.java	103
compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/source/SparkSourceUtil.java	38
compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/source/SparkTextFileBoundedSourceVertex.java	100
compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/SparkKeyExtractor.java	25
compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/SparkBroadcastVariables.java	23
compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/coder/SparkDecoderFactory.java	34
compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/coder/SparkEncoderFactory.java	34
compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/transform/FlatMapTransform.java	25
compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/transform/HDFSTextFileTransform.java	43
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/CollectTransform.java	26
compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/transform/MapTransform.java	25
compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/transform/MapToPairTransform.java	27
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/ReduceTransform.java	56
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/sql/NemoSparkUserFacingClass.java	20
compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/sql/Dataset.java	656
compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/sql/DataFrameReader.java	271
compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/sql/SparkSession.java	242
compiler/frontend/spark/src/main/scala/org/apache/nemo/compiler/frontend/spark/core/rdd/PairRDDFunctions.scala	222
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/Optimizer.java	9
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/runtime/Message.java	25
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/runtime/RunTimePass.java	6
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/runtime/DynamicTaskSizingRuntimePass.java	100
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/runtime/SkewRunTimePass.java	135
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/SkewHandlingUtil.java	54
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/LargeShuffleReshapingPass.java	23
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/pass/compiletime/reshaping/ReshapingPass.java	18
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/LoopExtractionPass.java	209
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/LoopUnrollingPass.java	43
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/SamplingSkewReshapingPass.java	85
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/LoopOptimizations.java	214
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/CommonSubexpressionEliminationPass.java	129
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/composite/CompositePass.java	40
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/composite/LargeShuffleCompositePass.java	12
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/composite/SkewCompositePass.java	12
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/composite/TransientResourceCompositePass.java	12
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/composite/LoopOptimizationCompositePass.java	17
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/composite/DefaultCompositePass.java	18
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/CompileTimePass.java	9
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/SkewAnnotatingPass.java	34
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/AnnotatingPass.java	25
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultEdgeEncoderPass.java	22
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/LargeShuffleAnnotatingPass.java	32
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/TransientResourcePriorityPass.java	42
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultDataStorePass.java	18
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/annotating/XGBoostPass.java	88
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/PipeTransferForAllEdgesPass.java	21
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultDataPersistencePass.java	29
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultParallelismPass.java	100
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/ResourceLocalityPass.java	16
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DisaggregationEdgeDataStorePass.java	22
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/DuplicateEdgeGroupSizePass.java	38
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultEdgeDecoderPass.java	22
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/ShuffleEdgePushPass.java	29
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/CompressionPass.java	26
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/TransientResourceDataTransferPass.java	43
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/ResourceSitePass.java	182
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/LambdaPass.java	15
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/ResourceSlotPass.java	16
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/Annotates.java	9
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/Requires.java	9
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/OptimizerUtils.java	43
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/DisaggregationPolicy.java	25
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/StreamingPolicy.java	22
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/DynamicTaskSizingPolicy.java	34
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/DefaultPolicyWithSeparatePass.java	34
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/TransientResourcePolicy.java	25
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/DefaultPolicy.java	21
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/SamplingLargeShuffleSkewPolicy.java	30
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/BasicPushPolicy.java	25
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/DataSkewPolicy.java	28
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/LambdaPolicy.java	22
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/LargeShufflePolicy.java	25
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/XGBoostPolicy.java	23
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/PolicyImpl.java	128
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/Policy.java	8
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/PolicyBuilder.java	78
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/ConditionalLargeShufflePolicy.java	31
compiler/backend/src/main/java/org/apache/nemo/compiler/backend/Backend.java	8
compiler/backend/src/main/java/org/apache/nemo/compiler/backend/nemo/NemoBackend.java	21
compiler/backend/src/main/java/org/apache/nemo/compiler/backend/nemo/prophet/SkewProphet.java	25
compiler/backend/src/main/java/org/apache/nemo/compiler/backend/nemo/prophet/ParallelismProphet.java	93
compiler/backend/src/main/java/org/apache/nemo/compiler/backend/nemo/prophet/Prophet.java	5
compiler/backend/src/main/java/org/apache/nemo/compiler/backend/nemo/NemoPlanRewriter.java	114