duplicated block id: 1 size: 88 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (3693:3805) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (4187:4299) duplicated block id: 2 size: 82 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (6110:6214) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (6510:6614) duplicated block id: 3 size: 77 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (4015:4108) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (4504:4597) duplicated block id: 4 size: 69 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Hopping/PartitionedSnapshotWindowHoppingPipe.cs (319:406) - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Sliding/PartitionedSnapshotWindowSlidingPipe.cs (317:404) duplicated block id: 5 size: 67 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Hopping/SnapshotWindowHoppingPipe.cs (257:342) - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Sliding/SnapshotWindowSlidingPipe.cs (256:341) duplicated block id: 6 size: 58 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (1033:1106) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (2832:2905) duplicated block id: 7 size: 58 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (2237:2310) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (2536:2609) duplicated block id: 8 size: 58 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Hopping/SnapshotWindowHoppingPipeSimple.cs (206:277) - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Sliding/SnapshotWindowSlidingPipeSimple.cs (205:276) duplicated block id: 9 size: 57 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (270:342) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (653:725) duplicated block id: 10 size: 56 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/PartitionedEquiJoinPipe.cs (591:652) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/PartitionedEquiJoinPipeCompound.cs (595:656) duplicated block id: 11 size: 55 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Clip/ClipJoinPipe.cs (86:151) - Sources/Core/Microsoft.StreamProcessing/Operators/LeftAntiSemiJoin/LeftAntiSemiJoinPipe.cs (130:197) duplicated block id: 12 size: 54 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/PartitionedEquiJoinPipe.cs (459:522) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/PartitionedEquiJoinPipeCompound.cs (463:526) duplicated block id: 13 size: 54 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/PartitionedEquiJoinPipe.cs (525:588) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/PartitionedEquiJoinPipeCompound.cs (529:592) duplicated block id: 14 size: 49 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (525:586) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (903:964) duplicated block id: 15 size: 44 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (6453:6497) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (7473:7517) duplicated block id: 16 size: 41 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Clip/PartitionedClipJoinPipe.cs (93:137) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/PartitionedEquiJoinPipe.cs (150:195) duplicated block id: 17 size: 41 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/StartEdge/PartitionedStartEdgeEquiJoinPipe.cs (125:170) - Sources/Core/Microsoft.StreamProcessing/Operators/LeftAntiSemiJoin/PartitionedLeftAntiSemiJoinPipe.cs (117:162) duplicated block id: 18 size: 39 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/SubscriptionBase.cs (1330:1373) - Sources/Core/Microsoft.StreamProcessing/Ingress/SubscriptionBase.cs (1951:1994) duplicated block id: 19 size: 39 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (2483:2522) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (3265:3304) duplicated block id: 20 size: 37 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (6848:6885) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (7706:7743) duplicated block id: 21 size: 35 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (4139:4174) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (5427:5462) duplicated block id: 22 size: 33 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/SubscriptionBase.cs (238:275) - Sources/Core/Microsoft.StreamProcessing/Ingress/SubscriptionBase.cs (751:788) duplicated block id: 23 size: 33 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (606:639) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (1635:1668) duplicated block id: 24 size: 32 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (2777:2809) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (3462:3494) duplicated block id: 25 size: 32 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (6065:6097) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (7247:7279) duplicated block id: 26 size: 28 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (4628:4656) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (5739:5767) duplicated block id: 27 size: 28 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/PartitionedEquiJoinPipe.cs (655:685) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/PartitionedEquiJoinPipeCompound.cs (659:689) duplicated block id: 28 size: 28 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Shuffle/ShuffleStreamable.cs (53:85) - Sources/Core/Microsoft.StreamProcessing/Operators/Shuffle/ShuffleStreamable.cs (201:233) duplicated block id: 29 size: 28 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/PriorityQueue/SnapshotWindowPriorityQueuePipe.cs (66:97) - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Sliding/PartitionedSnapshotWindowSlidingPipe.cs (64:95) duplicated block id: 30 size: 27 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/ImpatienceSorter.cs (58:95) - Sources/Core/Microsoft.StreamProcessing/Ingress/ImpatienceSorter.cs (465:502) duplicated block id: 31 size: 27 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (2196:2223) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (3075:3102) duplicated block id: 32 size: 26 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (984:1010) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (1910:1936) duplicated block id: 33 size: 26 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (1580:1615) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (1855:1890) duplicated block id: 34 size: 25 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (5376:5407) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (5688:5719) duplicated block id: 35 size: 25 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Clip/ClipJoinPipe.cs (154:184) - Sources/Core/Microsoft.StreamProcessing/Operators/LeftAntiSemiJoin/LeftAntiSemiJoinPipe.cs (200:230) duplicated block id: 36 size: 25 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Stitch/PartitionedStitchPipe.cs (149:177) - Sources/Core/Microsoft.StreamProcessing/Operators/Stitch/StitchPipe.cs (125:153) duplicated block id: 37 size: 24 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Clip/ClipJoinPipe.cs (187:216) - Sources/Core/Microsoft.StreamProcessing/Operators/LeftAntiSemiJoin/LeftAntiSemiJoinPipe.cs (233:262) duplicated block id: 38 size: 24 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Shuffle/ShufflePipe.cs (41:68) - Sources/Core/Microsoft.StreamProcessing/Operators/Shuffle/ShufflePipe.cs (348:375) duplicated block id: 39 size: 23 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Egress/Temporal/TemporalEgressTransformer.cs (37:66) - Sources/Core/Microsoft.StreamProcessing/Egress/TemporalArray/TemporalArrayEgressTransformer.cs (37:66) duplicated block id: 40 size: 23 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/SubscriptionBase.cs (295:321) - Sources/Core/Microsoft.StreamProcessing/Ingress/SubscriptionBase.cs (808:834) duplicated block id: 41 size: 23 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/SubscriptionBase.cs (1079:1103) - Sources/Core/Microsoft.StreamProcessing/Ingress/SubscriptionBase.cs (1700:1724) duplicated block id: 42 size: 23 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (3657:3680) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (5122:5145) duplicated block id: 43 size: 21 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/SubscriptionBase.cs (51:73) - Sources/Core/Microsoft.StreamProcessing/Ingress/SubscriptionBase.cs (564:586) duplicated block id: 44 size: 21 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (235:256) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (1367:1388) duplicated block id: 45 size: 20 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/PriorityQueue/PartitionedSnapshotWindowPriorityQueuePipeSimple.cs (52:73) - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Sliding/PartitionedSnapshotWindowSlidingPipeSimple.cs (52:73) duplicated block id: 46 size: 18 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/ImpatienceSorter.cs (232:255) - Sources/Core/Microsoft.StreamProcessing/Ingress/ImpatienceSorter.cs (639:662) duplicated block id: 47 size: 17 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Binary/BinaryIngress.cs (160:177) - Sources/Core/Microsoft.StreamProcessing/Ingress/Binary/BinaryIngress.cs (222:239) duplicated block id: 48 size: 16 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Events/StreamEvent.cs (140:156) - Sources/Core/Microsoft.StreamProcessing/Events/StreamEvent.cs (309:325) duplicated block id: 49 size: 16 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Binary/BinaryIngress.cs (130:146) - Sources/Core/Microsoft.StreamProcessing/Ingress/Binary/BinaryIngress.cs (191:207) duplicated block id: 50 size: 15 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Binary/BinaryIngress.cs (48:63) - Sources/Core/Microsoft.StreamProcessing/Ingress/Binary/BinaryIngress.cs (102:117) duplicated block id: 51 size: 15 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/SubscriptionBase.cs (1393:1410) - Sources/Core/Microsoft.StreamProcessing/Ingress/SubscriptionBase.cs (2014:2031) duplicated block id: 52 size: 15 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressStreamable.cs (572:587) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressStreamable.cs (589:604) duplicated block id: 53 size: 15 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressStreamable.cs (606:621) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressStreamable.cs (623:638) duplicated block id: 54 size: 15 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressStreamable.cs (1976:1991) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressStreamable.cs (1993:2008) duplicated block id: 55 size: 15 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressStreamable.cs (2010:2025) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressStreamable.cs (2027:2042) duplicated block id: 56 size: 15 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Hopping/SnapshotWindowHoppingPipeSimple.cs (292:308) - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Sliding/SnapshotWindowSlidingPipeSimple.cs (291:307) duplicated block id: 57 size: 14 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Aggregates/SlidingMaxAggregate.cs (61:76) - Sources/Core/Microsoft.StreamProcessing/Aggregates/SlidingMinAggregate.cs (61:76) duplicated block id: 58 size: 14 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Egress/TemporalArray/TemporalArrayEgressObservable.cs (53:68) - Sources/Core/Microsoft.StreamProcessing/Egress/TemporalArray/TemporalArrayEgressObservable.cs (90:105) duplicated block id: 59 size: 14 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Egress/TemporalArray/TemporalArrayEgressObservable.cs (160:175) - Sources/Core/Microsoft.StreamProcessing/Egress/TemporalArray/TemporalArrayEgressObservable.cs (197:212) duplicated block id: 60 size: 14 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Binary/BinaryIngress.cs (22:36) - Sources/Core/Microsoft.StreamProcessing/Ingress/Binary/BinaryIngress.cs (75:89) duplicated block id: 61 size: 14 cleaned lines of code in 3 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Clip/ClipJoinPipe.cs (375:391) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/FixedInterval/FixedIntervalEquiJoinPipe.cs (362:378) - Sources/Core/Microsoft.StreamProcessing/Operators/LeftAntiSemiJoin/LeftAntiSemiJoinPipe.cs (682:698) duplicated block id: 62 size: 14 cleaned lines of code in 4 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Clip/PartitionedClipJoinPipe.cs (526:542) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/FixedInterval/PartitionedFixedIntervalEquiJoinPipe.cs (490:506) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/FixedInterval/PartitionedFixedIntervalEquiJoinPipeCompound.cs (496:512) - Sources/Core/Microsoft.StreamProcessing/Operators/LeftAntiSemiJoin/PartitionedLeftAntiSemiJoinPipe.cs (788:804) duplicated block id: 63 size: 14 cleaned lines of code in 3 files: - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/EquiJoinPipe.cs (855:871) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/IncreasingOrder/IncreasingOrderEquiJoinPipe.cs (670:686) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/StartEdge/StartEdgeEquiJoinPipe.cs (361:377) duplicated block id: 64 size: 14 cleaned lines of code in 4 files: - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/PartitionedEquiJoinPipe.cs (958:974) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/PartitionedEquiJoinPipeCompound.cs (976:992) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/StartEdge/PartitionedStartEdgeEquiJoinPipe.cs (420:436) - Sources/Core/Microsoft.StreamProcessing/Operators/Union/PartitionedUnionPipe.cs (302:318) duplicated block id: 65 size: 14 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/PartitionedEquiJoinPipeSimple.cs (874:890) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/FixedInterval/PartitionedFixedIntervalEquiJoinPipeSimple.cs (466:482) duplicated block id: 66 size: 14 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/StartEdge/PartitionedStartEdgeEquiJoinPipe.cs (69:86) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/StartEdge/StartEdgeEquiJoinPipe.cs (47:64) duplicated block id: 67 size: 14 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Tumbling/PartitionedSnapshotWindowTumblingPipe.cs (198:214) - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Tumbling/PartitionedSnapshotWindowTumblingPipeSimple.cs (198:214) duplicated block id: 68 size: 14 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Stitch/PartitionedStitchPipe.cs (98:112) - Sources/Core/Microsoft.StreamProcessing/Operators/Stitch/StitchPipe.cs (74:88) duplicated block id: 69 size: 13 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Egress/Atemporal/AtemporalEgressPipe.cs (58:73) - Sources/Core/Microsoft.StreamProcessing/Egress/AtemporalArray/AtemporalArrayEgressPipe.cs (87:102) duplicated block id: 70 size: 13 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Binary/BinaryIngress.cs (337:350) - Sources/Core/Microsoft.StreamProcessing/Ingress/Binary/BinaryIngress.cs (388:401) duplicated block id: 71 size: 13 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Binary/BinaryIngress.cs (362:375) - Sources/Core/Microsoft.StreamProcessing/Ingress/Binary/BinaryIngress.cs (414:427) duplicated block id: 72 size: 13 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressStreamable.cs (229:242) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressStreamable.cs (244:257) duplicated block id: 73 size: 13 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressStreamable.cs (259:272) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressStreamable.cs (274:287) duplicated block id: 74 size: 13 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressStreamable.cs (674:687) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressStreamable.cs (2078:2091) duplicated block id: 75 size: 13 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressStreamable.cs (1630:1643) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressStreamable.cs (1645:1658) duplicated block id: 76 size: 13 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressStreamable.cs (1660:1673) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressStreamable.cs (1675:1688) duplicated block id: 77 size: 13 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Afa/GroupedAfaEventListTransformer.cs (17:30) - Sources/Core/Microsoft.StreamProcessing/Operators/Afa/GroupedAfaTransformer.cs (17:30) duplicated block id: 78 size: 13 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Afa/UngroupedAfaTransformer.cs (15:28) - Sources/Core/Microsoft.StreamProcessing/Operators/Afa/UngroupedDAfaTransformer.cs (15:28) duplicated block id: 79 size: 13 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Beat/BeatPipe.cs (48:64) - Sources/Core/Microsoft.StreamProcessing/Operators/Beat/PartitionedBeatPipe.cs (57:73) duplicated block id: 80 size: 13 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Clip/ClipJoinPipe.cs (394:409) - Sources/Core/Microsoft.StreamProcessing/Operators/LeftAntiSemiJoin/LeftAntiSemiJoinPipe.cs (701:716) duplicated block id: 81 size: 13 cleaned lines of code in 3 files: - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/FixedInterval/PartitionedFixedIntervalEquiJoinPipe.cs (430:443) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/FixedInterval/PartitionedFixedIntervalEquiJoinPipeCompound.cs (434:447) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/FixedInterval/PartitionedFixedIntervalEquiJoinPipeSimple.cs (432:445) duplicated block id: 82 size: 13 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Stitch/PartitionedStitchPipe.cs (127:141) - Sources/Core/Microsoft.StreamProcessing/Operators/Stitch/StitchPipe.cs (103:117) duplicated block id: 83 size: 12 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Collections/MultiSet.cs (66:79) - Sources/Core/Microsoft.StreamProcessing/Collections/SortedMultiSet.cs (170:183) duplicated block id: 84 size: 12 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Egress/Temporal/TemporalEgressObservable.cs (97:110) - Sources/Core/Microsoft.StreamProcessing/Egress/Temporal/TemporalEgressObservable.cs (165:178) duplicated block id: 85 size: 12 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Egress/Temporal/TemporalEgressObservable.cs (305:318) - Sources/Core/Microsoft.StreamProcessing/Egress/Temporal/TemporalEgressObservable.cs (373:386) duplicated block id: 86 size: 12 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (507:519) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (885:897) duplicated block id: 87 size: 12 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (3997:4009) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (4486:4498) duplicated block id: 88 size: 12 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/EquiJoinPipe.cs (892:906) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/PartitionedEquiJoinPipe.cs (998:1012) duplicated block id: 89 size: 12 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/MapReduce/MapDefinition.cs (19:31) - Sources/Core/Microsoft.StreamProcessing/Operators/MapReduce/MapDefinition.cs (118:130) duplicated block id: 90 size: 11 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Egress/TemporalArray/TemporalArrayEgressPipe.cs (100:111) - Sources/Core/Microsoft.StreamProcessing/Egress/TemporalArray/TemporalArrayEgressPipe.cs (175:186) duplicated block id: 91 size: 11 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Binary/BinaryIngress.cs (249:260) - Sources/Core/Microsoft.StreamProcessing/Ingress/Binary/BinaryIngress.cs (292:303) duplicated block id: 92 size: 11 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Binary/BinaryIngress.cs (270:281) - Sources/Core/Microsoft.StreamProcessing/Ingress/Binary/BinaryIngress.cs (314:325) duplicated block id: 93 size: 11 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/SubscriptionBase.cs (1443:1454) - Sources/Core/Microsoft.StreamProcessing/Ingress/SubscriptionBase.cs (2064:2075) duplicated block id: 94 size: 11 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/TemporalArray/TemporalArrayIngress.cs (56:67) - Sources/Core/Microsoft.StreamProcessing/Ingress/TemporalArray/TemporalArrayIngress.cs (283:294) duplicated block id: 95 size: 11 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/EquiJoinPipe.cs (127:138) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/PartitionedEquiJoinPipe.cs (119:130) duplicated block id: 96 size: 11 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/PartitionedEquiJoinPipeSimple.cs (129:141) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/FixedInterval/PartitionedFixedIntervalEquiJoinPipeSimple.cs (90:102) duplicated block id: 97 size: 11 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Group/GroupPipe.cs (31:43) - Sources/Core/Microsoft.StreamProcessing/Operators/Group/GroupPipe.cs (132:144) duplicated block id: 98 size: 11 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/MapReduce/MapDefinition.cs (57:70) - Sources/Core/Microsoft.StreamProcessing/Operators/MapReduce/MapDefinition.cs (155:168) duplicated block id: 99 size: 11 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/QuantizeLifetime/PartitionedQuantizeLifetimePipe.cs (37:49) - Sources/Core/Microsoft.StreamProcessing/Operators/QuantizeLifetime/QuantizeLifetimePipe.cs (40:52) duplicated block id: 100 size: 11 cleaned lines of code in 3 files: - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Hopping/PartitionedSnapshotWindowHoppingPipeSimple.cs (347:358) - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Sliding/PartitionedSnapshotWindowSlidingPipeSimple.cs (347:358) - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/StartEdge/PartitionedSnapshotWindowStartEdgePipeSimple.cs (238:249) duplicated block id: 101 size: 11 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Ungroup/UngroupPipe.cs (32:43) - Sources/Core/Microsoft.StreamProcessing/Operators/Ungroup/UngroupPipe.cs (125:136) duplicated block id: 102 size: 10 cleaned lines of code in 4 files: - Sources/Core/Microsoft.StreamProcessing/Egress/Atemporal/AtemporalEgressObservable.cs (16:27) - Sources/Core/Microsoft.StreamProcessing/Egress/Atemporal/AtemporalEgressObservable.cs (43:54) - Sources/Core/Microsoft.StreamProcessing/Egress/StreamMessage/StreamMessageEgressObservable.cs (16:27) - Sources/Core/Microsoft.StreamProcessing/Egress/Temporal/TemporalEgressObservable.cs (24:35) duplicated block id: 103 size: 10 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/EndEdgeFreeOutput/EndEdgeFreeOutputPipe.cs (222:233) - Sources/Core/Microsoft.StreamProcessing/Operators/EndEdgeFreeOutput/PartitionedEndEdgeFreeOutputPipe.cs (241:252) duplicated block id: 104 size: 10 cleaned lines of code in 3 files: - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/PartitionedEquiJoinPipe.cs (94:104) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/PartitionedEquiJoinPipeCompound.cs (93:103) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/PartitionedEquiJoinPipeSimple.cs (91:101) duplicated block id: 105 size: 10 cleaned lines of code in 3 files: - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/PartitionedEquiJoinPipe.cs (107:117) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/PartitionedEquiJoinPipeCompound.cs (106:116) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/PartitionedEquiJoinPipeSimple.cs (104:114) duplicated block id: 106 size: 10 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/StartEdge/PartitionedStartEdgeEquiJoinPipe.cs (88:98) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/StartEdge/StartEdgeEquiJoinPipe.cs (66:76) duplicated block id: 107 size: 10 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/LeftAntiSemiJoin/LeftAntiSemiJoinPipe.cs (115:125) - Sources/Core/Microsoft.StreamProcessing/Operators/LeftAntiSemiJoin/PartitionedLeftAntiSemiJoinPipe.cs (81:91) duplicated block id: 108 size: 10 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/SelectMany/SelectManyPipe.cs (34:45) - Sources/Core/Microsoft.StreamProcessing/Operators/SelectMany/SelectManyPipe.cs (162:173) duplicated block id: 109 size: 9 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Aggregates/SlidingMaxAggregate.cs (20:30) - Sources/Core/Microsoft.StreamProcessing/Aggregates/SlidingMinAggregate.cs (20:30) duplicated block id: 110 size: 9 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Collections/FastLinkedList.cs (316:325) - Sources/Core/Microsoft.StreamProcessing/Collections/FastLinkedList.cs (333:342) duplicated block id: 111 size: 9 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Egress/Temporal/TemporalEgress.cs (104:114) - Sources/Core/Microsoft.StreamProcessing/Egress/Temporal/TemporalEgress.cs (165:175) duplicated block id: 112 size: 9 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Egress/Temporal/TemporalEgress.cs (299:309) - Sources/Core/Microsoft.StreamProcessing/Egress/Temporal/TemporalEgress.cs (370:380) duplicated block id: 113 size: 9 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Egress/TemporalArray/TemporalArrayEgressPipe.cs (27:36) - Sources/Core/Microsoft.StreamProcessing/Egress/TemporalArray/TemporalArrayEgressPipe.cs (247:256) duplicated block id: 114 size: 9 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Egress/TemporalArray/TemporalArrayEgressPipe.cs (69:78) - Sources/Core/Microsoft.StreamProcessing/Egress/TemporalArray/TemporalArrayEgressPipe.cs (292:301) duplicated block id: 115 size: 9 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Egress/TemporalArray/TemporalArrayEgressPipe.cs (144:153) - Sources/Core/Microsoft.StreamProcessing/Egress/TemporalArray/TemporalArrayEgressPipe.cs (217:226) duplicated block id: 116 size: 9 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (4110:4119) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs (4599:4608) duplicated block id: 117 size: 9 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/TemporalArray/TemporalArrayIngress.cs (28:37) - Sources/Core/Microsoft.StreamProcessing/Ingress/TemporalArray/TemporalArrayIngress.cs (254:263) duplicated block id: 118 size: 9 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Afa/CompiledGroupedAfaPipe_EventList.cs (36:46) - Sources/Core/Microsoft.StreamProcessing/Operators/Afa/CompiledGroupedAfaPipe_MultiEventList.cs (36:46) duplicated block id: 119 size: 9 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/AlterLifetime/AlterLifetimeStartDependentDurationPipe.cs (34:44) - Sources/Core/Microsoft.StreamProcessing/Operators/AlterLifetime/PartitionedAlterLifetimeStartDependentDurationPipe.cs (36:46) duplicated block id: 120 size: 9 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/AlterLifetime/AlterLifetimeVariableDurationPipe.cs (34:45) - Sources/Core/Microsoft.StreamProcessing/Operators/AlterLifetime/PartitionedAlterLifetimeVariableDurationPipe.cs (36:47) duplicated block id: 121 size: 9 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Beat/BeatPipe.cs (433:443) - Sources/Core/Microsoft.StreamProcessing/Operators/Beat/PartitionedBeatPipe.cs (440:450) duplicated block id: 122 size: 9 cleaned lines of code in 4 files: - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/PartitionedEquiJoinPipe.cs (132:142) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/PartitionedEquiJoinPipeCompound.cs (131:141) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/FixedInterval/PartitionedFixedIntervalEquiJoinPipe.cs (93:103) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/FixedInterval/PartitionedFixedIntervalEquiJoinPipeCompound.cs (92:102) duplicated block id: 123 size: 9 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/FixedInterval/FixedIntervalEquiJoinPipe.cs (91:100) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/FixedInterval/PartitionedFixedIntervalEquiJoinPipe.cs (82:91) duplicated block id: 124 size: 9 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/IncreasingOrder/IncreasingOrderEquiJoinPipe.cs (689:699) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/StartEdge/StartEdgeEquiJoinPipe.cs (380:390) duplicated block id: 125 size: 9 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/LeftAntiSemiJoin/LeftAntiSemiJoinPipe.cs (719:729) - Sources/Core/Microsoft.StreamProcessing/Operators/LeftAntiSemiJoin/PartitionedLeftAntiSemiJoinPipe.cs (826:836) duplicated block id: 126 size: 9 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/SelectMany/SelectManyPipe.cs (127:136) - Sources/Core/Microsoft.StreamProcessing/Operators/SelectMany/SelectManyPipe.cs (255:264) duplicated block id: 127 size: 9 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/SessionWindow/PartitionedSessionWindowPipe.cs (40:49) - Sources/Core/Microsoft.StreamProcessing/Operators/SessionWindow/SessionWindowPipe.cs (39:48) duplicated block id: 128 size: 9 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Shuffle/ShufflePipe.cs (291:300) - Sources/Core/Microsoft.StreamProcessing/Operators/Shuffle/ShufflePipe.cs (580:589) duplicated block id: 129 size: 9 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/StreamableAPI/LifetimeExtensions.cs (280:290) - Sources/Core/Microsoft.StreamProcessing/StreamableAPI/LifetimeExtensions.cs (298:308) duplicated block id: 130 size: 8 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Collections/MultiSet.cs (92:100) - Sources/Core/Microsoft.StreamProcessing/Collections/SortedMultiSet.cs (261:269) duplicated block id: 131 size: 8 cleaned lines of code in 3 files: - Sources/Core/Microsoft.StreamProcessing/Egress/Atemporal/AtemporalEgressPipe.cs (75:83) - Sources/Core/Microsoft.StreamProcessing/Egress/AtemporalArray/AtemporalArrayEgressPipe.cs (104:112) - Sources/Core/Microsoft.StreamProcessing/Egress/AtemporalEnumerable/AtemporalEnumerableEgressPipe.cs (94:102) duplicated block id: 132 size: 8 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Egress/Temporal/TemporalEgressObservable.cs (131:141) - Sources/Core/Microsoft.StreamProcessing/Egress/Temporal/TemporalEgressObservable.cs (199:209) duplicated block id: 133 size: 8 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Egress/Temporal/TemporalEgressObservable.cs (339:349) - Sources/Core/Microsoft.StreamProcessing/Egress/Temporal/TemporalEgressObservable.cs (407:417) duplicated block id: 134 size: 8 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/ImpatienceSorter.cs (281:290) - Sources/Core/Microsoft.StreamProcessing/Ingress/ImpatienceSorter.cs (688:698) duplicated block id: 135 size: 8 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/AlterLifetime/AlterLifetimeConstantDurationPipe.cs (33:42) - Sources/Core/Microsoft.StreamProcessing/Operators/AlterLifetime/PartitionedAlterLifetimeConstantDurationPipe.cs (35:44) duplicated block id: 136 size: 8 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Clip/ClipJoinPipe.cs (73:81) - Sources/Core/Microsoft.StreamProcessing/Operators/Clip/PartitionedClipJoinPipe.cs (67:75) duplicated block id: 137 size: 8 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Clip/ClipJoinPipe.cs (412:421) - Sources/Core/Microsoft.StreamProcessing/Operators/Clip/PartitionedClipJoinPipe.cs (567:576) duplicated block id: 138 size: 8 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/ClipByConstant/ClipByConstantPipe.cs (32:40) - Sources/Core/Microsoft.StreamProcessing/Operators/ClipByConstant/PartitionedClipByConstantPipe.cs (35:43) duplicated block id: 139 size: 8 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/EquiJoinPipe.cs (286:294) - Sources/Core/Microsoft.StreamProcessing/Operators/LeftAntiSemiJoin/LeftAntiSemiJoinPipe.cs (276:284) duplicated block id: 140 size: 8 cleaned lines of code in 4 files: - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/PartitionedEquiJoinPipe.cs (448:456) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/PartitionedEquiJoinPipeCompound.cs (452:460) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/PartitionedEquiJoinPipeSimple.cs (432:440) - Sources/Core/Microsoft.StreamProcessing/Operators/LeftAntiSemiJoin/PartitionedLeftAntiSemiJoinPipe.cs (398:406) duplicated block id: 141 size: 8 cleaned lines of code in 3 files: - Sources/Core/Microsoft.StreamProcessing/Operators/ExtendLifetime/ExtendLifetimePipe.cs (35:43) - Sources/Core/Microsoft.StreamProcessing/Operators/ExtendLifetime/PartitionedExtendLifetimeNegativePipe.cs (39:47) - Sources/Core/Microsoft.StreamProcessing/Operators/ExtendLifetime/PartitionedExtendLifetimePipe.cs (35:43) duplicated block id: 142 size: 8 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/LeftAntiSemiJoin/PartitionedLeftAntiSemiJoinPipe.cs (101:109) - Sources/Core/Microsoft.StreamProcessing/Operators/Union/PartitionedUnionPipe.cs (167:175) duplicated block id: 143 size: 8 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Stitch/PartitionedStitchPipe.cs (115:124) - Sources/Core/Microsoft.StreamProcessing/Operators/Stitch/StitchPipe.cs (91:100) duplicated block id: 144 size: 7 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Collections/MultiSet.cs (50:57) - Sources/Core/Microsoft.StreamProcessing/Collections/SortedMultiSet.cs (121:128) duplicated block id: 145 size: 7 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Egress/Temporal/TemporalEgress.cs (83:91) - Sources/Core/Microsoft.StreamProcessing/Egress/Temporal/TemporalEgress.cs (144:152) duplicated block id: 146 size: 7 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Egress/Temporal/TemporalEgress.cs (277:285) - Sources/Core/Microsoft.StreamProcessing/Egress/Temporal/TemporalEgress.cs (348:356) duplicated block id: 147 size: 7 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Egress/Temporal/TemporalEgressObservable.cs (143:151) - Sources/Core/Microsoft.StreamProcessing/Egress/Temporal/TemporalEgressObservable.cs (211:219) duplicated block id: 148 size: 7 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Egress/Temporal/TemporalEgressPipe.cs (56:63) - Sources/Core/Microsoft.StreamProcessing/Egress/Temporal/TemporalEgressPipe.cs (95:102) duplicated block id: 149 size: 7 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/ImpatienceSorter.cs (44:51) - Sources/Core/Microsoft.StreamProcessing/Ingress/ImpatienceSorter.cs (451:458) duplicated block id: 150 size: 7 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/SubscriptionBase.cs (281:288) - Sources/Core/Microsoft.StreamProcessing/Ingress/SubscriptionBase.cs (794:801) duplicated block id: 151 size: 7 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/SubscriptionBase.cs (339:347) - Sources/Core/Microsoft.StreamProcessing/Ingress/SubscriptionBase.cs (852:860) duplicated block id: 152 size: 7 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/SubscriptionBase.cs (479:487) - Sources/Core/Microsoft.StreamProcessing/Ingress/SubscriptionBase.cs (992:1000) duplicated block id: 153 size: 7 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/SubscriptionBase.cs (1473:1481) - Sources/Core/Microsoft.StreamProcessing/Ingress/SubscriptionBase.cs (2094:2102) duplicated block id: 154 size: 7 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Afa/Regex.cs (38:45) - Sources/Core/Microsoft.StreamProcessing/Operators/Afa/Regex.cs (68:75) duplicated block id: 155 size: 7 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Clip/ClipJoinPipe.cs (228:235) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/FixedInterval/FixedIntervalEquiJoinPipe.cs (272:279) duplicated block id: 156 size: 7 cleaned lines of code in 4 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Clip/PartitionedClipJoinPipe.cs (379:386) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/FixedInterval/PartitionedFixedIntervalEquiJoinPipe.cs (402:409) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/FixedInterval/PartitionedFixedIntervalEquiJoinPipeCompound.cs (406:413) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/FixedInterval/PartitionedFixedIntervalEquiJoinPipeSimple.cs (386:393) duplicated block id: 157 size: 7 cleaned lines of code in 19 files: - Sources/Core/Microsoft.StreamProcessing/Operators/ClipByConstant/ClipByConstantPipe.cs (161:168) - Sources/Core/Microsoft.StreamProcessing/Operators/ClipByConstant/PartitionedClipByConstantPipe.cs (208:215) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/FixedInterval/FixedIntervalEquiJoinPipe.cs (393:400) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/FixedInterval/PartitionedFixedIntervalEquiJoinPipe.cs (524:531) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/FixedInterval/PartitionedFixedIntervalEquiJoinPipeCompound.cs (530:537) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/FixedInterval/PartitionedFixedIntervalEquiJoinPipeSimple.cs (500:507) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/IncreasingOrder/IncreasingOrderEquiJoinPipe.cs (701:708) - Sources/Core/Microsoft.StreamProcessing/Operators/ExtendLifetime/ExtendLifetimeNegativePipe.cs (191:198) - Sources/Core/Microsoft.StreamProcessing/Operators/ExtendLifetime/ExtendLifetimePipe.cs (132:139) - Sources/Core/Microsoft.StreamProcessing/Operators/ExtendLifetime/PartitionedExtendLifetimeNegativePipe.cs (245:252) - Sources/Core/Microsoft.StreamProcessing/Operators/ExtendLifetime/PartitionedExtendLifetimePipe.cs (178:185) - Sources/Core/Microsoft.StreamProcessing/Operators/PointAtEnd/PartitionedPointAtEndPipe.cs (154:161) - Sources/Core/Microsoft.StreamProcessing/Operators/PointAtEnd/PointAtEndPipe.cs (117:124) - Sources/Core/Microsoft.StreamProcessing/Operators/QuantizeLifetime/PartitionedQuantizeLifetimePipe.cs (176:183) - Sources/Core/Microsoft.StreamProcessing/Operators/QuantizeLifetime/QuantizeLifetimePipe.cs (140:147) - Sources/Core/Microsoft.StreamProcessing/Operators/SessionWindow/PartitionedSessionWindowPipe.cs (228:235) - Sources/Core/Microsoft.StreamProcessing/Operators/SessionWindow/SessionWindowPipe.cs (198:205) - Sources/Core/Microsoft.StreamProcessing/Operators/Union/PartitionedUnionPipe.cs (346:353) - Sources/Core/Microsoft.StreamProcessing/Operators/Union/UnionPipe.cs (273:280) duplicated block id: 158 size: 7 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/IncreasingOrder/IncreasingOrderEquiJoinPipe.cs (571:579) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/StartEdge/StartEdgeEquiJoinPipe.cs (330:338) duplicated block id: 159 size: 7 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/ExtendLifetime/ExtendLifetimeNegativePipe.cs (220:227) - Sources/Core/Microsoft.StreamProcessing/Operators/ExtendLifetime/PartitionedExtendLifetimeNegativePipe.cs (285:292) duplicated block id: 160 size: 7 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/LeftAntiSemiJoin/LeftAntiSemiJoinPipe.cs (750:757) - Sources/Core/Microsoft.StreamProcessing/Operators/LeftAntiSemiJoin/PartitionedLeftAntiSemiJoinPipe.cs (921:928) duplicated block id: 161 size: 7 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/MapReduce/MapReduceStreamable.cs (54:61) - Sources/Core/Microsoft.StreamProcessing/Operators/MapReduce/MapReduceStreamable.cs (246:253) duplicated block id: 162 size: 7 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/PointAtEnd/PartitionedPointAtEndPipe.cs (31:38) - Sources/Core/Microsoft.StreamProcessing/Operators/PointAtEnd/PointAtEndPipe.cs (30:37) duplicated block id: 163 size: 7 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Select/SelectPipe.cs (26:33) - Sources/Core/Microsoft.StreamProcessing/Operators/Select/SelectPipe.cs (87:94) duplicated block id: 164 size: 7 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Shuffle/ShufflePipe.cs (72:79) - Sources/Core/Microsoft.StreamProcessing/Operators/Shuffle/ShufflePipe.cs (379:386) duplicated block id: 165 size: 7 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Shuffle/ShufflePipe.cs (81:88) - Sources/Core/Microsoft.StreamProcessing/Operators/Shuffle/ShufflePipe.cs (388:395) duplicated block id: 166 size: 7 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Shuffle/ShufflePipe.cs (90:97) - Sources/Core/Microsoft.StreamProcessing/Operators/Shuffle/ShufflePipe.cs (397:404) duplicated block id: 167 size: 7 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Shuffle/ShufflePipe.cs (269:278) - Sources/Core/Microsoft.StreamProcessing/Operators/Shuffle/ShufflePipe.cs (558:567) duplicated block id: 168 size: 7 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Shuffle/ShufflePipe.cs (280:289) - Sources/Core/Microsoft.StreamProcessing/Operators/Shuffle/ShufflePipe.cs (569:578) duplicated block id: 169 size: 7 cleaned lines of code in 13 files: - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Hopping/SnapshotWindowHoppingPipe.cs (344:351) - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Hopping/SnapshotWindowHoppingPipeSimple.cs (279:286) - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/PriorityQueue/SnapshotWindowPriorityQueuePipe.cs (338:345) - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/PriorityQueue/SnapshotWindowPriorityQueuePipeSimple.cs (273:280) - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Sliding/SnapshotWindowSlidingPipe.cs (343:350) - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Sliding/SnapshotWindowSlidingPipeSimple.cs (278:285) - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/StartEdge/PartitionedSnapshotWindowStartEdgePipe.cs (269:276) - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/StartEdge/SnapshotWindowStartEdgePipe.cs (220:227) - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/StartEdge/SnapshotWindowStartEdgePipeSimple.cs (181:188) - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Tumbling/PartitionedSnapshotWindowTumblingPipe.cs (249:256) - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Tumbling/PartitionedSnapshotWindowTumblingPipeSimple.cs (245:252) - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Tumbling/SnapshotWindowTumblingPipe.cs (186:193) - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Tumbling/SnapshotWindowTumblingPipeSimple.cs (176:183) duplicated block id: 170 size: 7 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Union/PartitionedUnionPipe.cs (48:55) - Sources/Core/Microsoft.StreamProcessing/Operators/Union/UnionPipe.cs (29:36) duplicated block id: 171 size: 7 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/StreamableAPI/LifetimeExtensions.cs (194:202) - Sources/Core/Microsoft.StreamProcessing/StreamableAPI/LifetimeExtensions.cs (209:217) duplicated block id: 172 size: 6 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Aggregates/PercentileContinuous.cs (18:24) - Sources/Core/Microsoft.StreamProcessing/Aggregates/PercentileDiscrete.cs (18:24) duplicated block id: 173 size: 6 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Collections/CircularBuffer.cs (255:261) - Sources/Core/Microsoft.StreamProcessing/Collections/PooledCircularBuffer.cs (248:254) duplicated block id: 174 size: 6 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Egress/Temporal/TemporalEgressObservable.cs (77:83) - Sources/Core/Microsoft.StreamProcessing/Egress/Temporal/TemporalEgressObservable.cs (285:291) duplicated block id: 175 size: 6 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Events/StreamEvent.cs (158:164) - Sources/Core/Microsoft.StreamProcessing/Events/StreamEvent.cs (327:333) duplicated block id: 176 size: 6 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Atemporal/AtemporalIngressSubscription.cs (98:104) - Sources/Core/Microsoft.StreamProcessing/Ingress/Atemporal/AtemporalIngressSubscription.cs (159:165) duplicated block id: 177 size: 6 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/DiagnosticObservable.cs (21:27) - Sources/Core/Microsoft.StreamProcessing/Ingress/DiagnosticObservable.cs (94:100) duplicated block id: 178 size: 6 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/DiagnosticObservable.cs (29:35) - Sources/Core/Microsoft.StreamProcessing/Ingress/DiagnosticObservable.cs (102:108) duplicated block id: 179 size: 6 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/DiagnosticObservable.cs (37:43) - Sources/Core/Microsoft.StreamProcessing/Ingress/DiagnosticObservable.cs (110:116) duplicated block id: 180 size: 6 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/SubscriptionBase.cs (383:389) - Sources/Core/Microsoft.StreamProcessing/Ingress/SubscriptionBase.cs (896:902) duplicated block id: 181 size: 6 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressStreamable.cs (157:163) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressStreamable.cs (1558:1564) duplicated block id: 182 size: 6 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressStreamable.cs (837:843) - Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressStreamable.cs (2242:2248) duplicated block id: 183 size: 6 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Afa/Regex.cs (24:30) - Sources/Core/Microsoft.StreamProcessing/Operators/Afa/Regex.cs (53:59) duplicated block id: 184 size: 6 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Afa/Regex.cs (272:278) - Sources/Core/Microsoft.StreamProcessing/Operators/Afa/Regex.cs (301:307) duplicated block id: 185 size: 6 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Afa/Regex.cs (520:526) - Sources/Core/Microsoft.StreamProcessing/Operators/Afa/Regex.cs (534:540) duplicated block id: 186 size: 6 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Clip/ClipJoinPipe.cs (439:445) - Sources/Core/Microsoft.StreamProcessing/Operators/Clip/PartitionedClipJoinPipe.cs (651:657) duplicated block id: 187 size: 6 cleaned lines of code in 3 files: - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/EquiJoinPipe.cs (925:931) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/PartitionedEquiJoinPipe.cs (1095:1101) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/PartitionedEquiJoinPipeCompound.cs (1113:1119) duplicated block id: 188 size: 6 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/FixedInterval/PartitionedFixedIntervalEquiJoinPipe.cs (412:418) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/FixedInterval/PartitionedFixedIntervalEquiJoinPipeCompound.cs (416:422) duplicated block id: 189 size: 6 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/FixedInterval/PartitionedFixedIntervalEquiJoinPipe.cs (421:427) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/FixedInterval/PartitionedFixedIntervalEquiJoinPipeCompound.cs (425:431) duplicated block id: 190 size: 6 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/StartEdge/PartitionedStartEdgeEquiJoinPipe.cs (475:481) - Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/StartEdge/StartEdgeEquiJoinPipe.cs (392:398) duplicated block id: 191 size: 6 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/ExtendLifetime/ExtendLifetimePipe.cs (159:165) - Sources/Core/Microsoft.StreamProcessing/Operators/ExtendLifetime/PartitionedExtendLifetimePipe.cs (214:220) duplicated block id: 192 size: 6 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Group/GroupStreamable.cs (39:45) - Sources/Core/Microsoft.StreamProcessing/Operators/Group/GroupStreamable.cs (124:130) duplicated block id: 193 size: 6 cleaned lines of code in 8 files: - Sources/Core/Microsoft.StreamProcessing/Operators/GroupedWindow/GroupedWindowPipe.cs (352:358) - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Hopping/PartitionedSnapshotWindowHoppingPipe.cs (408:414) - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Hopping/PartitionedSnapshotWindowHoppingPipeSimple.cs (325:331) - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/PriorityQueue/PartitionedSnapshotWindowPriorityQueuePipe.cs (386:392) - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/PriorityQueue/PartitionedSnapshotWindowPriorityQueuePipeSimple.cs (321:327) - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Sliding/PartitionedSnapshotWindowSlidingPipe.cs (406:412) - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Sliding/PartitionedSnapshotWindowSlidingPipeSimple.cs (325:331) - Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/StartEdge/PartitionedSnapshotWindowStartEdgePipeSimple.cs (226:232) duplicated block id: 194 size: 6 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/QuantizeLifetime/PartitionedQuantizeLifetimePipe.cs (212:218) - Sources/Core/Microsoft.StreamProcessing/Operators/QuantizeLifetime/QuantizeLifetimePipe.cs (167:173) duplicated block id: 195 size: 6 cleaned lines of code in 2 files: - Sources/Core/Microsoft.StreamProcessing/Operators/Ungroup/UngroupStreamable.cs (35:41) - Sources/Core/Microsoft.StreamProcessing/Operators/Ungroup/UngroupStreamable.cs (115:121)