11 duplicated lines in:
  - common/src/main/java/org/apache/nemo/common/ir/vertex/transform/StreamTransform.java (41:58, 61%)
  - compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/FlattenTransform.java (38:55, 68%)

8 duplicated lines in:
  - common/src/main/java/org/apache/nemo/common/ir/vertex/transform/StreamTransform.java (46:58, 44%)
  - compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/WindowFnTransform.java (91:102, 20%)

8 duplicated lines in:
  - common/src/main/java/org/apache/nemo/common/ir/vertex/transform/StreamTransform.java (46:58, 44%)
  - compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/SideInputTransform.java (50:61, 36%)

8 duplicated lines in:
  - common/src/main/java/org/apache/nemo/common/ir/vertex/CachedSourceVertex.java (63:76, 18%)
  - compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/source/SparkDatasetBoundedSourceVertex.java (82:93, 10%)

7 duplicated lines in:
  - common/src/main/java/org/apache/nemo/common/PairKeyExtractor.java (37:47, 46%)
  - compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/BeamKeyExtractor.java (43:53, 41%)

7 duplicated lines in:
  - common/src/main/java/org/apache/nemo/common/PairKeyExtractor.java (37:47, 46%)
  - compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/SparkKeyExtractor.java (39:49, 46%)

6 duplicated lines in:
  - common/src/main/java/org/apache/nemo/common/punctuation/Watermark.java (45:51, 26%)
  - compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultScheduleGroupPass.java (215:221, 5%)

6 duplicated lines in:
  - common/src/main/java/org/apache/nemo/common/ir/edge/IREdge.java (112:118, 13%)
  - compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultParallelismPass.java (138:144, 7%)

6 duplicated lines in:
  - common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/ClonedSchedulingProperty.java (128:135, 10%)
  - compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultScheduleGroupPass.java (215:221, 5%)

6 duplicated lines in:
  - common/src/main/java/org/apache/nemo/common/HashRange.java (104:110, 13%)
  - compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultParallelismPass.java (138:144, 7%)

6 duplicated lines in:
  - common/src/main/java/org/apache/nemo/common/HashRange.java (104:110, 13%)
  - compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultScheduleGroupPass.java (215:221, 5%)

6 duplicated lines in:
  - common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/ClonedSchedulingProperty.java (128:135, 10%)
  - compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultParallelismPass.java (138:144, 7%)

6 duplicated lines in:
  - common/src/main/java/org/apache/nemo/common/punctuation/LatencyMark.java (95:101, 15%)
  - compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultParallelismPass.java (138:144, 7%)

6 duplicated lines in:
  - common/src/main/java/org/apache/nemo/common/ir/edge/IREdge.java (112:118, 13%)
  - compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultScheduleGroupPass.java (215:221, 5%)

6 duplicated lines in:
  - common/src/main/java/org/apache/nemo/common/punctuation/LatencyMark.java (95:101, 15%)
  - compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultScheduleGroupPass.java (215:221, 5%)

6 duplicated lines in:
  - common/src/main/java/org/apache/nemo/common/punctuation/Watermark.java (45:51, 26%)
  - compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultParallelismPass.java (138:144, 7%)