Path	Lines of Code
common/src/main/java/org/apache/nemo/common/ByteBufferInputStream.java	28
common/src/main/java/org/apache/nemo/common/Cloneable.java	4
common/src/main/java/org/apache/nemo/common/HashRange.java	62
common/src/main/java/org/apache/nemo/common/KeyExtractor.java	5
common/src/main/java/org/apache/nemo/common/KeyRange.java	14
common/src/main/java/org/apache/nemo/common/Pair.java	36
common/src/main/java/org/apache/nemo/common/PairKeyExtractor.java	23
common/src/main/java/org/apache/nemo/common/StateMachine.java	169
common/src/main/java/org/apache/nemo/common/Util.java	171
common/src/main/java/org/apache/nemo/common/coder/BytesDecoderFactory.java	50
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/IntDecoderFactory.java	30
common/src/main/java/org/apache/nemo/common/coder/IntEncoderFactory.java	30
common/src/main/java/org/apache/nemo/common/coder/LongDecoderFactory.java	30
common/src/main/java/org/apache/nemo/common/coder/LongEncoderFactory.java	30
common/src/main/java/org/apache/nemo/common/coder/PairDecoderFactory.java	49
common/src/main/java/org/apache/nemo/common/coder/PairEncoderFactory.java	51
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/DAGInterface.java	42
common/src/main/java/org/apache/nemo/common/dag/Edge.java	33
common/src/main/java/org/apache/nemo/common/dag/Vertex.java	20
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/CompilerEventHandler.java	3
common/src/main/java/org/apache/nemo/common/eventhandler/PubSubEventHandlerWrapper.java	13
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/exception/BlockFetchException.java	6
common/src/main/java/org/apache/nemo/common/exception/BlockWriteException.java	6
common/src/main/java/org/apache/nemo/common/exception/CompileTimeOptimizationException.java	9
common/src/main/java/org/apache/nemo/common/exception/ContainerException.java	6
common/src/main/java/org/apache/nemo/common/exception/DataSourceException.java	6
common/src/main/java/org/apache/nemo/common/exception/DynamicOptimizationException.java	9
common/src/main/java/org/apache/nemo/common/exception/IllegalEdgeOperationException.java	9
common/src/main/java/org/apache/nemo/common/exception/IllegalMessageException.java	6
common/src/main/java/org/apache/nemo/common/exception/IllegalStateTransitionException.java	6
common/src/main/java/org/apache/nemo/common/exception/IllegalVertexOperationException.java	6
common/src/main/java/org/apache/nemo/common/exception/InvalidParameterException.java	6
common/src/main/java/org/apache/nemo/common/exception/InvalidUserMainException.java	9
common/src/main/java/org/apache/nemo/common/exception/JsonParseException.java	6
common/src/main/java/org/apache/nemo/common/exception/MetricException.java	9
common/src/main/java/org/apache/nemo/common/exception/NodeConnectionException.java	6
common/src/main/java/org/apache/nemo/common/exception/OutputMismatchException.java	9
common/src/main/java/org/apache/nemo/common/exception/PhysicalPlanGenerationException.java	9
common/src/main/java/org/apache/nemo/common/exception/RuntimeOptimizationException.java	9
common/src/main/java/org/apache/nemo/common/exception/SchedulingException.java	6
common/src/main/java/org/apache/nemo/common/exception/SimulationException.java	9
common/src/main/java/org/apache/nemo/common/exception/UnknownExecutionStateException.java	6
common/src/main/java/org/apache/nemo/common/exception/UnknownFailureCauseException.java	6
common/src/main/java/org/apache/nemo/common/exception/UnrecoverableFailureException.java	6
common/src/main/java/org/apache/nemo/common/exception/UnsupportedBlockStoreException.java	6
common/src/main/java/org/apache/nemo/common/exception/UnsupportedCommPatternException.java	6
common/src/main/java/org/apache/nemo/common/exception/UnsupportedCompressionException.java	6
common/src/main/java/org/apache/nemo/common/exception/UnsupportedExecutionPropertyException.java	6
common/src/main/java/org/apache/nemo/common/exception/UnsupportedMethodException.java	6
common/src/main/java/org/apache/nemo/common/exception/UnsupportedMetricException.java	6
common/src/main/java/org/apache/nemo/common/exception/UnsupportedPartitionerException.java	6
common/src/main/java/org/apache/nemo/common/ir/BoundedIteratorReadable.java	18
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/IdManager.java	50
common/src/main/java/org/apache/nemo/common/ir/OutputCollector.java	10
common/src/main/java/org/apache/nemo/common/ir/Readable.java	12
common/src/main/java/org/apache/nemo/common/ir/edge/IREdge.java	69
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/BlockFetchFailureProperty.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/CommunicationPatternProperty.java	16
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/DataFlowProperty.java	14
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/DataStoreProperty.java	17
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/DecompressionProperty.java	10
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/DuplicateEdgeGroupPropertyValue.java	49
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/KeyDecoderProperty.java	11
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/KeyExtractorProperty.java	11
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/PartitionSetProperty.java	12
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/SubPartitionSetProperty.java	12
common/src/main/java/org/apache/nemo/common/ir/executionproperty/AssociatedProperty.java	8
common/src/main/java/org/apache/nemo/common/ir/executionproperty/EdgeExecutionProperty.java	7
common/src/main/java/org/apache/nemo/common/ir/executionproperty/ExecutionProperty.java	35
common/src/main/java/org/apache/nemo/common/ir/executionproperty/ExecutionPropertyMap.java	126
common/src/main/java/org/apache/nemo/common/ir/executionproperty/ResourceSpecification.java	47
common/src/main/java/org/apache/nemo/common/ir/executionproperty/VertexExecutionProperty.java	7
common/src/main/java/org/apache/nemo/common/ir/vertex/CachedSourceVertex.java	66
common/src/main/java/org/apache/nemo/common/ir/vertex/IRVertex.java	50
common/src/main/java/org/apache/nemo/common/ir/vertex/InMemorySourceVertex.java	76
common/src/main/java/org/apache/nemo/common/ir/vertex/LoopVertex.java	245
common/src/main/java/org/apache/nemo/common/ir/vertex/OperatorVertex.java	27
common/src/main/java/org/apache/nemo/common/ir/vertex/SourceVertex.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/executionproperty/EnableDynamicTaskSizingProperty.java	10
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/MessageIdVertexProperty.java	10
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/ResourceAntiAffinityProperty.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/ResourceLocalityProperty.java	12
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/ResourceSlotProperty.java	13
common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/ScheduleGroupProperty.java	10
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/MessageGeneratorTransform.java	41
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/SignalTransform.java	29
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/Transform.java	18
common/src/main/java/org/apache/nemo/common/ir/vertex/utility/RelayVertex.java	8
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/TaskSizeSplitterVertex.java	321
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/partitioner/DedicatedKeyPerElement.java	7
common/src/main/java/org/apache/nemo/common/partitioner/DedicatedKeyPerElementPartitioner.java	12
common/src/main/java/org/apache/nemo/common/partitioner/HashPartitioner.java	15
common/src/main/java/org/apache/nemo/common/partitioner/IntactPartitioner.java	7
common/src/main/java/org/apache/nemo/common/partitioner/Partitioner.java	43
common/src/main/java/org/apache/nemo/common/pass/Pass.java	19
common/src/main/java/org/apache/nemo/common/punctuation/Finishmark.java	9
common/src/main/java/org/apache/nemo/common/punctuation/LatencyMark.java	54
common/src/main/java/org/apache/nemo/common/punctuation/Watermark.java	35