duplicated block id: 1 size: 30 cleaned lines of code in 2 files: - wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/sources/fs/JavaCSVTableSource.java (173:210) - wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/fs/FileUtils.java (57:93) duplicated block id: 2 size: 20 cleaned lines of code in 2 files: - wayang-benchmark/src/main/scala/org/apache/wayang/apps/kmeans/Kmeans.scala (108:140) - wayang-benchmark/src/main/scala/org/apache/wayang/apps/kmeans/postgres/Kmeans.scala (108:140) duplicated block id: 3 size: 17 cleaned lines of code in 2 files: - wayang-platforms/wayang-generic-jdbc/src/main/java/org/apache/wayang/genericjdbc/operators/GenericSqlToStreamOperator.java (175:193) - wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/operators/SqlToStreamOperator.java (181:199) duplicated block id: 4 size: 13 cleaned lines of code in 2 files: - wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/KafkaTopicSink.java (160:177) - wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/KafkaTopicSource.java (139:156) duplicated block id: 5 size: 12 cleaned lines of code in 2 files: - wayang-platforms/wayang-giraph/src/main/java/org/apache/wayang/giraph/execution/GiraphExecutor.java (57:71) - wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/execution/TensorflowExecutor.java (53:67) duplicated block id: 6 size: 12 cleaned lines of code in 2 files: - wayang-platforms/wayang-generic-jdbc/src/main/java/org/apache/wayang/genericjdbc/mapping/ProjectionMapping.java (52:65) - wayang-platforms/wayang-postgres/src/main/java/org/apache/wayang/postgres/mapping/ProjectionMapping.java (52:65) duplicated block id: 7 size: 10 cleaned lines of code in 2 files: - wayang-benchmark/src/main/scala/org/apache/wayang/apps/kmeans/Kmeans.scala (167:178) - wayang-benchmark/src/main/scala/org/apache/wayang/apps/kmeans/postgres/Kmeans.scala (167:178) duplicated block id: 8 size: 9 cleaned lines of code in 2 files: - wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/Formats.java (32:42) - wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/model/measurement/TimeMeasurement.java (191:201) duplicated block id: 9 size: 9 cleaned lines of code in 2 files: - wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/MapPartitionsDescriptor.java (85:95) - wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/FlatMapDescriptor.java (82:92) duplicated block id: 10 size: 9 cleaned lines of code in 2 files: - wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/ObjectFileSinkMapping.java (47:57) - wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/ObjectFileSinkMapping.java (49:59) duplicated block id: 11 size: 9 cleaned lines of code in 3 files: - wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/ObjectFileSourceMapping.java (50:60) - wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/ObjectFileSourceMapping.java (51:61) - wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/ObjectFileSourceMapping.java (49:59) duplicated block id: 12 size: 9 cleaned lines of code in 2 files: - wayang-platforms/wayang-generic-jdbc/src/main/java/org/apache/wayang/genericjdbc/operators/GenericSqlToStreamOperator.java (208:218) - wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/operators/SqlToStreamOperator.java (214:224) duplicated block id: 13 size: 9 cleaned lines of code in 2 files: - wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/spark_helpers/BitSetJoin.java (51:61) - wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/java_helpers/BitSetJoin.java (47:57) duplicated block id: 14 size: 8 cleaned lines of code in 2 files: - wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/CoGroupOperator.java (49:58) - wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/JoinOperator.java (48:57) duplicated block id: 15 size: 8 cleaned lines of code in 2 files: - wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkRepeatExpandedOperator.java (200:209) - wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkRepeatOperator.java (135:144) duplicated block id: 16 size: 7 cleaned lines of code in 2 files: - wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/PredicateDescriptor.java (69:77) - wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/ConsumerDescriptor.java (64:72) duplicated block id: 17 size: 7 cleaned lines of code in 2 files: - wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/DoWhileOperator.java (186:194) - wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/RepeatOperator.java (150:158) duplicated block id: 18 size: 7 cleaned lines of code in 3 files: - wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkMapOperator.java (112:120) - wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkMapPartitionsOperator.java (128:136) - wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkFlatMapOperator.java (127:135) duplicated block id: 19 size: 7 cleaned lines of code in 2 files: - wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/FilterMapping.java (43:51) - wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/DoWhileMapping.java (41:49) duplicated block id: 20 size: 7 cleaned lines of code in 2 files: - wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/MapPartitionsMapping.java (41:49) - wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/MapMapping.java (41:49) duplicated block id: 21 size: 7 cleaned lines of code in 4 files: - wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/FilterMapping.java (42:50) - wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/FlatMapMapping.java (41:49) - wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/GlobalMaterializedGroupMapping.java (41:49) - wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/DoWhileMapping.java (43:51) duplicated block id: 22 size: 7 cleaned lines of code in 2 files: - wayang-platforms/wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/mapping/FilterMapping.java (41:49) - wayang-platforms/wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/mapping/ProjectionMapping.java (42:50) duplicated block id: 23 size: 6 cleaned lines of code in 2 files: - wayang-api/wayang-api-json/src/main/scala/operatorfromjson/PlanFromJson.scala (53:60) - wayang-api/wayang-api-json/src/main/scala/operatorfromjson/OperatorFromJson.scala (117:124) duplicated block id: 24 size: 6 cleaned lines of code in 2 files: - wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/ProbabilisticDoubleInterval.java (68:76) - wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/ProbabilisticIntervalEstimate.java (56:64) duplicated block id: 25 size: 6 cleaned lines of code in 2 files: - wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/ProbabilisticDoubleInterval.java (135:142) - wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/ProbabilisticIntervalEstimate.java (139:146) duplicated block id: 26 size: 6 cleaned lines of code in 2 files: - wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/IEJoinOperator.java (78:85) - wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/IESelfJoinOperator.java (68:75)