common/src/main/java/org/apache/nemo/common/ir/vertex/transform/StreamTransform.java
compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/FlattenTransform.java

common/src/main/java/org/apache/nemo/common/ir/vertex/transform/StreamTransform.java
compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/WindowFnTransform.java

common/src/main/java/org/apache/nemo/common/ir/vertex/transform/StreamTransform.java
compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/SideInputTransform.java

common/src/main/java/org/apache/nemo/common/ir/vertex/CachedSourceVertex.java
compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/source/SparkDatasetBoundedSourceVertex.java

common/src/main/java/org/apache/nemo/common/PairKeyExtractor.java
compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/BeamKeyExtractor.java

common/src/main/java/org/apache/nemo/common/PairKeyExtractor.java
compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/SparkKeyExtractor.java

common/src/main/java/org/apache/nemo/common/punctuation/Watermark.java
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultScheduleGroupPass.java

common/src/main/java/org/apache/nemo/common/ir/edge/IREdge.java
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultParallelismPass.java

common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/ClonedSchedulingProperty.java
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultScheduleGroupPass.java

common/src/main/java/org/apache/nemo/common/HashRange.java
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultParallelismPass.java

common/src/main/java/org/apache/nemo/common/HashRange.java
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultScheduleGroupPass.java

common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/ClonedSchedulingProperty.java
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultParallelismPass.java

common/src/main/java/org/apache/nemo/common/punctuation/LatencyMark.java
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultParallelismPass.java

common/src/main/java/org/apache/nemo/common/ir/edge/IREdge.java
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultScheduleGroupPass.java

common/src/main/java/org/apache/nemo/common/punctuation/LatencyMark.java
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultScheduleGroupPass.java

common/src/main/java/org/apache/nemo/common/punctuation/Watermark.java
compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultParallelismPass.java