duplicated block id: 1 size: 17 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java (106:137) - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java (106:137) duplicated block id: 2 size: 17 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (100:120) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java (101:121) duplicated block id: 3 size: 17 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (130:150) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java (131:151) duplicated block id: 4 size: 13 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java (302:324) - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java (301:323) duplicated block id: 5 size: 12 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java (86:101) - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java (178:193) duplicated block id: 6 size: 12 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java (86:101) - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java (182:197) duplicated block id: 7 size: 11 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java (198:214) - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java (202:219) duplicated block id: 8 size: 11 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (109:126) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (139:156) duplicated block id: 9 size: 10 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AggregateSessionWindowFire.java (44:56) - core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AggregateWindowFire.java (43:55) duplicated block id: 10 size: 10 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java (110:124) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java (140:154) duplicated block id: 11 size: 10 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java (266:284) - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java (270:287) duplicated block id: 12 size: 9 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (109:120) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java (140:151) duplicated block id: 13 size: 9 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java (91:101) - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java (187:197) duplicated block id: 14 size: 9 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java (183:193) - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java (187:197) duplicated block id: 15 size: 9 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (246:258) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java (227:239) duplicated block id: 16 size: 9 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/AccumulatorSupplier.java (65:76) - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/AggregateSupplier.java (66:77) duplicated block id: 17 size: 9 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (65:79) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (81:95) duplicated block id: 18 size: 9 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AccumulatorSessionWindowFire.java (46:57) - core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AccumulatorWindowFire.java (44:56) duplicated block id: 19 size: 9 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java (91:101) - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java (91:101) duplicated block id: 20 size: 9 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (139:150) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java (110:121) duplicated block id: 21 size: 9 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java (183:193) - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java (91:101) duplicated block id: 22 size: 8 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/topology/real/ProcessorFactory.java (31:42) - core/src/main/java/org/apache/rocketmq/streams/core/topology/real/SinkFactory.java (31:43) duplicated block id: 23 size: 8 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/state/AbstractStore.java (187:196) - core/src/main/java/org/apache/rocketmq/streams/core/state/AbstractStore.java (204:213) duplicated block id: 24 size: 7 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/topology/real/ProcessorFactory.java (32:42) - core/src/main/java/org/apache/rocketmq/streams/core/topology/real/SourceFactory.java (34:44) duplicated block id: 25 size: 7 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (161:171) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (236:246) duplicated block id: 26 size: 7 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (85:95) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (236:246) duplicated block id: 27 size: 7 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (116:126) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (206:216) duplicated block id: 28 size: 7 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (85:95) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (161:171) duplicated block id: 29 size: 7 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (69:79) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (161:171) duplicated block id: 30 size: 7 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java (71:81) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java (198:209) duplicated block id: 31 size: 7 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (85:95) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (146:156) duplicated block id: 32 size: 7 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (206:216) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (236:246) duplicated block id: 33 size: 7 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (69:79) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (146:156) duplicated block id: 34 size: 7 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (85:95) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (206:216) duplicated block id: 35 size: 7 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java (71:81) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java (216:227) duplicated block id: 36 size: 7 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (116:126) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (161:171) duplicated block id: 37 size: 7 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java (198:209) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java (216:227) duplicated block id: 38 size: 7 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (161:171) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (206:216) duplicated block id: 39 size: 7 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/serialization/deImpl/KVJsonDeserializer.java (34:43) - core/src/main/java/org/apache/rocketmq/streams/core/serialization/serImpl/KVJsonSerializer.java (30:38) duplicated block id: 40 size: 7 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (69:79) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (236:246) duplicated block id: 41 size: 7 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (69:79) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (206:216) duplicated block id: 42 size: 7 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (146:156) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (206:216) duplicated block id: 43 size: 7 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (85:95) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (116:126) duplicated block id: 44 size: 7 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (69:79) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (116:126) duplicated block id: 45 size: 7 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (146:156) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (161:171) duplicated block id: 46 size: 7 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (146:156) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (236:246) duplicated block id: 47 size: 7 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/topology/real/SinkFactory.java (32:43) - core/src/main/java/org/apache/rocketmq/streams/core/topology/real/SourceFactory.java (34:44) duplicated block id: 48 size: 7 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (116:126) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java (236:246) duplicated block id: 49 size: 6 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/serialization/deImpl/KVJsonDeserializer.java (34:39) - core/src/main/java/org/apache/rocketmq/streams/core/util/Utils.java (43:48) duplicated block id: 50 size: 6 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AccumulatorSessionWindowFire.java (65:70) - core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AggregateSessionWindowFire.java (64:69) duplicated block id: 51 size: 6 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java (117:124) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java (161:168) duplicated block id: 52 size: 6 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java (220:228) - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java (224:232) duplicated block id: 53 size: 6 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/serialization/serImpl/KVJsonSerializer.java (30:35) - core/src/main/java/org/apache/rocketmq/streams/core/util/Utils.java (43:48) duplicated block id: 54 size: 6 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java (87:94) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java (216:224) duplicated block id: 55 size: 6 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java (59:64) - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java (59:64) duplicated block id: 56 size: 6 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java (120:127) - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java (203:209) duplicated block id: 57 size: 6 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/AggregateSupplier.java (38:45) - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/AggregateSupplier.java (59:66) duplicated block id: 58 size: 6 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java (71:78) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java (87:94) duplicated block id: 59 size: 6 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java (203:209) - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java (120:126) duplicated block id: 60 size: 6 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java (120:126) - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java (207:213) duplicated block id: 61 size: 6 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/util/RocketMQUtil.java (53:63) - core/src/main/java/org/apache/rocketmq/streams/core/util/RocketMQUtil.java (124:134) duplicated block id: 62 size: 6 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java (253:263) - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java (257:267) duplicated block id: 63 size: 6 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java (87:94) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java (198:206) duplicated block id: 64 size: 6 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java (120:127) - core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java (207:213) duplicated block id: 65 size: 6 cleaned lines of code in 2 files: - core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java (147:154) - core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java (161:168)