duplicated block id: 1
size: 58 cleaned lines of code
in 2 files:
 - banyand/measure/flusher.go (28:90)
 - banyand/stream/flusher.go (28:90)

duplicated block id: 2
size: 50 cleaned lines of code
in 2 files:
 - banyand/measure/merger_policy.go (53:117)
 - banyand/stream/merger_policy.go (49:113)

duplicated block id: 3
size: 47 cleaned lines of code
in 2 files:
 - banyand/measure/merger.go (36:88)
 - banyand/stream/merger.go (36:88)

duplicated block id: 4
size: 41 cleaned lines of code
in 2 files:
 - banyand/measure/tstable.go (133:175)
 - banyand/stream/tstable.go (65:107)

duplicated block id: 5
size: 41 cleaned lines of code
in 2 files:
 - banyand/measure/block_writer.go (201:246)
 - banyand/stream/block_writer.go (195:240)

duplicated block id: 6
size: 35 cleaned lines of code
in 2 files:
 - banyand/measure/part_iter.go (198:238)
 - banyand/stream/part_iter.go (198:238)

duplicated block id: 7
size: 33 cleaned lines of code
in 2 files:
 - banyand/measure/flusher.go (144:178)
 - banyand/stream/flusher.go (144:178)

duplicated block id: 8
size: 30 cleaned lines of code
in 2 files:
 - banyand/measure/metrics.go (213:249)
 - banyand/stream/metrics.go (212:248)

duplicated block id: 9
size: 29 cleaned lines of code
in 2 files:
 - banyand/measure/introducer.go (113:143)
 - banyand/stream/introducer.go (113:143)

duplicated block id: 10
size: 27 cleaned lines of code
in 2 files:
 - banyand/measure/tstable.go (311:341)
 - banyand/stream/tstable.go (326:356)

duplicated block id: 11
size: 27 cleaned lines of code
in 2 files:
 - banyand/measure/merger.go (236:265)
 - banyand/stream/merger.go (236:265)

duplicated block id: 12
size: 26 cleaned lines of code
in 2 files:
 - banyand/measure/flusher.go (114:142)
 - banyand/stream/flusher.go (114:142)

duplicated block id: 13
size: 24 cleaned lines of code
in 2 files:
 - banyand/measure/part_iter.go (133:161)
 - banyand/stream/part_iter.go (133:161)

duplicated block id: 14
size: 22 cleaned lines of code
in 3 files:
 - pkg/pb/v1/value.go (233:256)
 - banyand/measure/datapoints.go (110:133)
 - banyand/stream/elements.go (110:133)

duplicated block id: 15
size: 21 cleaned lines of code
in 2 files:
 - banyand/measure/part_iter.go (109:131)
 - banyand/stream/part_iter.go (109:131)

duplicated block id: 16
size: 20 cleaned lines of code
in 2 files:
 - banyand/measure/snapshot.go (177:198)
 - banyand/stream/snapshot.go (227:248)

duplicated block id: 17
size: 18 cleaned lines of code
in 2 files:
 - banyand/measure/tstable.go (216:235)
 - banyand/stream/tstable.go (148:167)

duplicated block id: 18
size: 18 cleaned lines of code
in 2 files:
 - banyand/measure/primary_metadata.go (106:125)
 - banyand/stream/primary_metadata.go (106:125)

duplicated block id: 19
size: 18 cleaned lines of code
in 2 files:
 - banyand/measure/block_reader.go (146:165)
 - banyand/stream/block_reader.go (143:162)

duplicated block id: 20
size: 17 cleaned lines of code
in 2 files:
 - banyand/measure/primary_metadata.go (85:104)
 - banyand/stream/primary_metadata.go (85:104)

duplicated block id: 21
size: 17 cleaned lines of code
in 2 files:
 - banyand/measure/block_reader.go (187:209)
 - banyand/stream/block_reader.go (184:206)

duplicated block id: 22
size: 16 cleaned lines of code
in 2 files:
 - banyand/measure/tstable.go (197:214)
 - banyand/stream/tstable.go (129:146)

duplicated block id: 23
size: 16 cleaned lines of code
in 2 files:
 - banyand/measure/merger.go (201:221)
 - banyand/stream/merger.go (201:221)

duplicated block id: 24
size: 16 cleaned lines of code
in 2 files:
 - banyand/measure/flusher.go (95:112)
 - banyand/stream/flusher.go (95:112)

duplicated block id: 25
size: 16 cleaned lines of code
in 2 files:
 - banyand/measure/block_reader.go (167:185)
 - banyand/stream/block_reader.go (164:182)

duplicated block id: 26
size: 16 cleaned lines of code
in 2 files:
 - banyand/measure/part.go (250:267)
 - banyand/stream/part.go (228:245)

duplicated block id: 27
size: 15 cleaned lines of code
in 2 files:
 - banyand/measure/tstable.go (343:360)
 - banyand/stream/tstable.go (358:375)

duplicated block id: 28
size: 15 cleaned lines of code
in 2 files:
 - banyand/measure/part_iter.go (276:292)
 - banyand/stream/part_iter.go (273:289)

duplicated block id: 29
size: 15 cleaned lines of code
in 2 files:
 - banyand/measure/block_writer.go (150:166)
 - banyand/stream/block_writer.go (146:162)

duplicated block id: 30
size: 14 cleaned lines of code
in 2 files:
 - banyand/measure/tstable.go (291:309)
 - banyand/stream/tstable.go (306:324)

duplicated block id: 31
size: 14 cleaned lines of code
in 2 files:
 - banyand/measure/part_iter.go (163:180)
 - banyand/stream/part_iter.go (163:180)

duplicated block id: 32
size: 14 cleaned lines of code
in 2 files:
 - banyand/measure/part_metadata.go (64:81)
 - banyand/stream/part_metadata.go (64:81)

duplicated block id: 33
size: 14 cleaned lines of code
in 2 files:
 - banyand/measure/part_metadata.go (83:98)
 - banyand/stream/part_metadata.go (83:98)

duplicated block id: 34
size: 14 cleaned lines of code
in 2 files:
 - banyand/measure/part.go (104:119)
 - banyand/stream/part.go (100:115)

duplicated block id: 35
size: 13 cleaned lines of code
in 2 files:
 - banyand/measure/tstable.go (362:379)
 - banyand/stream/tstable.go (377:394)

duplicated block id: 36
size: 13 cleaned lines of code
in 2 files:
 - banyand/measure/snapshot.go (200:214)
 - banyand/stream/snapshot.go (250:264)

duplicated block id: 37
size: 13 cleaned lines of code
in 2 files:
 - banyand/measure/part_iter.go (76:90)
 - banyand/stream/part_iter.go (76:90)

duplicated block id: 38
size: 13 cleaned lines of code
in 2 files:
 - banyand/measure/part_iter.go (294:308)
 - banyand/stream/part_iter.go (291:305)

duplicated block id: 39
size: 13 cleaned lines of code
in 2 files:
 - banyand/measure/block_writer.go (259:277)
 - banyand/stream/block_writer.go (253:271)

duplicated block id: 40
size: 13 cleaned lines of code
in 2 files:
 - banyand/measure/primary_metadata.go (69:83)
 - banyand/stream/primary_metadata.go (69:83)

duplicated block id: 41
size: 13 cleaned lines of code
in 2 files:
 - banyand/measure/datapoints.go (94:108)
 - banyand/stream/elements.go (94:108)

duplicated block id: 42
size: 12 cleaned lines of code
in 2 files:
 - banyand/measure/metadata.go (102:115)
 - banyand/stream/metadata.go (77:90)

duplicated block id: 43
size: 12 cleaned lines of code
in 2 files:
 - banyand/measure/snapshot.go (107:120)
 - banyand/stream/snapshot.go (108:121)

duplicated block id: 44
size: 12 cleaned lines of code
in 2 files:
 - banyand/measure/snapshot.go (122:135)
 - banyand/stream/snapshot.go (123:136)

duplicated block id: 45
size: 12 cleaned lines of code
in 2 files:
 - banyand/measure/block_metadata.go (302:315)
 - banyand/stream/block_metadata.go (314:327)

duplicated block id: 46
size: 12 cleaned lines of code
in 2 files:
 - banyand/measure/part_iter.go (182:196)
 - banyand/stream/part_iter.go (182:196)

duplicated block id: 47
size: 11 cleaned lines of code
in 2 files:
 - banyand/measure/merger.go (90:102)
 - banyand/stream/merger.go (90:102)

duplicated block id: 48
size: 11 cleaned lines of code
in 2 files:
 - banyand/measure/gc.go (45:57)
 - banyand/stream/gc.go (45:57)

duplicated block id: 49
size: 11 cleaned lines of code
in 2 files:
 - banyand/measure/block_reader.go (57:69)
 - banyand/stream/block_reader.go (57:69)

duplicated block id: 50
size: 11 cleaned lines of code
in 2 files:
 - banyand/internal/storage/tsdb.go (259:271)
 - banyand/property/db.go (193:205)

duplicated block id: 51
size: 10 cleaned lines of code
in 2 files:
 - banyand/measure/snapshot.go (68:79)
 - banyand/stream/snapshot.go (69:80)

duplicated block id: 52
size: 10 cleaned lines of code
in 2 files:
 - banyand/measure/block_writer.go (279:290)
 - banyand/stream/block_writer.go (273:284)

duplicated block id: 53
size: 10 cleaned lines of code
in 3 files:
 - banyand/measure/service.go (112:123)
 - banyand/stream/service.go (112:123)
 - banyand/property/service.go (75:86)

duplicated block id: 54
size: 10 cleaned lines of code
in 2 files:
 - banyand/measure/part_metadata.go (51:62)
 - banyand/stream/part_metadata.go (51:62)

duplicated block id: 55
size: 9 cleaned lines of code
in 2 files:
 - banyand/measure/tstable.go (177:187)
 - banyand/stream/tstable.go (109:119)

duplicated block id: 56
size: 9 cleaned lines of code
in 2 files:
 - banyand/measure/metadata.go (132:142)
 - banyand/stream/metadata.go (107:117)

duplicated block id: 57
size: 9 cleaned lines of code
in 2 files:
 - banyand/measure/block_metadata.go (87:97)
 - banyand/stream/block_metadata.go (87:97)

duplicated block id: 58
size: 9 cleaned lines of code
in 2 files:
 - banyand/measure/part_iter.go (49:59)
 - banyand/stream/part_iter.go (49:59)

duplicated block id: 59
size: 9 cleaned lines of code
in 2 files:
 - banyand/measure/part_iter.go (61:74)
 - banyand/stream/part_iter.go (61:74)

duplicated block id: 60
size: 9 cleaned lines of code
in 2 files:
 - banyand/measure/primary_metadata.go (47:58)
 - banyand/stream/primary_metadata.go (47:58)

duplicated block id: 61
size: 9 cleaned lines of code
in 2 files:
 - banyand/measure/write.go (62:72)
 - banyand/stream/write.go (59:69)

duplicated block id: 62
size: 8 cleaned lines of code
in 2 files:
 - banyand/measure/snapshot.go (40:49)
 - banyand/stream/snapshot.go (41:50)

duplicated block id: 63
size: 8 cleaned lines of code
in 2 files:
 - banyand/measure/snapshot.go (85:94)
 - banyand/stream/snapshot.go (86:95)

duplicated block id: 64
size: 8 cleaned lines of code
in 2 files:
 - banyand/measure/snapshot.go (96:105)
 - banyand/stream/snapshot.go (97:106)

duplicated block id: 65
size: 8 cleaned lines of code
in 2 files:
 - banyand/measure/part_iter.go (310:319)
 - banyand/stream/part_iter.go (307:316)

duplicated block id: 66
size: 8 cleaned lines of code
in 2 files:
 - banyand/measure/block_writer.go (248:257)
 - banyand/stream/block_writer.go (242:251)

duplicated block id: 67
size: 8 cleaned lines of code
in 2 files:
 - banyand/measure/merger.go (223:232)
 - banyand/stream/merger.go (223:232)

duplicated block id: 68
size: 8 cleaned lines of code
in 2 files:
 - banyand/measure/merger_policy.go (119:130)
 - banyand/stream/merger_policy.go (115:126)

duplicated block id: 69
size: 8 cleaned lines of code
in 2 files:
 - banyand/measure/write.go (51:60)
 - banyand/stream/write.go (48:57)

duplicated block id: 70
size: 7 cleaned lines of code
in 2 files:
 - banyand/measure/snapshot.go (141:149)
 - banyand/stream/snapshot.go (185:193)

duplicated block id: 71
size: 7 cleaned lines of code
in 2 files:
 - banyand/measure/part_iter.go (99:107)
 - banyand/stream/part_iter.go (99:107)

duplicated block id: 72
size: 7 cleaned lines of code
in 2 files:
 - banyand/measure/merger.go (181:189)
 - banyand/stream/merger.go (181:189)

duplicated block id: 73
size: 7 cleaned lines of code
in 2 files:
 - banyand/measure/query.go (440:448)
 - banyand/stream/query.go (396:404)

duplicated block id: 74
size: 7 cleaned lines of code
in 2 files:
 - banyand/measure/query.go (450:458)
 - banyand/stream/query.go (406:414)

duplicated block id: 75
size: 7 cleaned lines of code
in 2 files:
 - banyand/measure/query.go (460:468)
 - banyand/stream/query.go (416:424)

duplicated block id: 76
size: 7 cleaned lines of code
in 2 files:
 - banyand/measure/query.go (470:478)
 - banyand/stream/query.go (426:434)

duplicated block id: 77
size: 7 cleaned lines of code
in 2 files:
 - banyand/measure/query.go (480:488)
 - banyand/stream/query.go (436:444)

duplicated block id: 78
size: 7 cleaned lines of code
in 2 files:
 - banyand/measure/part_metadata.go (41:49)
 - banyand/stream/part_metadata.go (41:49)

duplicated block id: 79
size: 7 cleaned lines of code
in 2 files:
 - banyand/measure/block_reader.go (136:144)
 - banyand/stream/block_reader.go (133:141)

duplicated block id: 80
size: 6 cleaned lines of code
in 3 files:
 - pkg/query/logical/measure/measure_plan.go (49:56)
 - pkg/query/logical/stream/stream_analyzer.go (145:152)
 - pkg/query/logical/stream/stream_plan_distributed.go (306:313)

duplicated block id: 81
size: 6 cleaned lines of code
in 3 files:
 - pkg/run/channel_closer.go (117:124)
 - pkg/run/closer.go (95:102)
 - pkg/run/channel_group_closer.go (52:59)

duplicated block id: 82
size: 6 cleaned lines of code
in 2 files:
 - banyand/measure/primary_metadata.go (60:67)
 - banyand/stream/primary_metadata.go (60:67)

duplicated block id: 83
size: 6 cleaned lines of code
in 2 files:
 - banyand/measure/primary_metadata.go (127:134)
 - banyand/stream/primary_metadata.go (127:134)

duplicated block id: 84
size: 6 cleaned lines of code
in 2 files:
 - banyand/measure/merger.go (172:179)
 - banyand/stream/merger.go (172:179)

duplicated block id: 85
size: 6 cleaned lines of code
in 2 files:
 - banyand/measure/trace.go (35:43)
 - banyand/stream/trace.go (35:43)

duplicated block id: 86
size: 6 cleaned lines of code
in 2 files:
 - banyand/measure/flusher.go (180:187)
 - banyand/stream/flusher.go (180:187)

duplicated block id: 87
size: 6 cleaned lines of code
in 2 files:
 - banyand/measure/block_reader.go (38:45)
 - banyand/stream/block_reader.go (38:45)

duplicated block id: 88
size: 6 cleaned lines of code
in 2 files:
 - banyand/measure/introducer.go (88:95)
 - banyand/stream/introducer.go (88:95)

duplicated block id: 89
size: 6 cleaned lines of code
in 2 files:
 - banyand/measure/introducer.go (205:212)
 - banyand/stream/introducer.go (204:211)

duplicated block id: 90
size: 6 cleaned lines of code
in 2 files:
 - banyand/measure/block.go (78:85)
 - banyand/stream/block.go (72:79)

duplicated block id: 91
size: 6 cleaned lines of code
in 2 files:
 - banyand/measure/block.go (1016:1023)
 - banyand/stream/block.go (756:763)