duplicated block id: 1 size: 20 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterProcessingTime.java (97:128) - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterWatermark.java (134:165) duplicated block id: 2 size: 20 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/Counter.java (383:403) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/Counter.java (559:579) duplicated block id: 3 size: 20 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterProcessingTime.java (97:128) - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterSynchronizedProcessingTime.java (76:107) duplicated block id: 4 size: 20 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterSynchronizedProcessingTime.java (76:107) - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterWatermark.java (134:165) duplicated block id: 5 size: 17 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PubsubReader.java (73:92) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedWindmillReader.java (81:100) duplicated block id: 6 size: 16 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/AvroIOTranslator.java (80:98) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/TextIOTranslator.java (85:104) duplicated block id: 7 size: 16 cleaned lines of code in 2 files: - contrib/join-library/src/main/java/com/google/cloud/dataflow/contrib/joinlibrary/Join.java (97:116) - contrib/join-library/src/main/java/com/google/cloud/dataflow/contrib/joinlibrary/Join.java (150:169) duplicated block id: 8 size: 16 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/Counter.java (563:579) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/Counter.java (878:894) duplicated block id: 9 size: 16 cleaned lines of code in 2 files: - sdk/src/main/proto/proto2_coder_test_messages.proto (1:17) - sdk/src/main/proto/windmill.proto (1:17) duplicated block id: 10 size: 16 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/Counter.java (387:403) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/Counter.java (878:894) duplicated block id: 11 size: 15 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AssignWindowsParDoFn.java (58:78) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ReifyTimestampAndWindowsParDoFn.java (53:73) duplicated block id: 12 size: 14 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/io/AvroIO.java (629:657) - sdk/src/main/java/com/google/cloud/dataflow/sdk/io/TextIO.java (665:694) duplicated block id: 13 size: 14 cleaned lines of code in 2 files: - contrib/join-library/src/main/java/com/google/cloud/dataflow/contrib/joinlibrary/Join.java (52:69) - contrib/join-library/src/main/java/com/google/cloud/dataflow/contrib/joinlibrary/Join.java (101:118) duplicated block id: 14 size: 14 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AssignWindowsParDoFn.java (65:78) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/NormalParDoFn.java (77:90) duplicated block id: 15 size: 14 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ReduceFnContextFactory.java (238:261) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ReduceFnContextFactory.java (333:356) duplicated block id: 16 size: 14 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AssignWindowsParDoFn.java (65:78) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/CombineValuesFn.java (83:96) duplicated block id: 17 size: 14 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ReduceFnContextFactory.java (238:261) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ReduceFnContextFactory.java (280:303) duplicated block id: 18 size: 14 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/CombineValuesFn.java (83:96) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ReifyTimestampAndWindowsParDoFn.java (60:73) duplicated block id: 19 size: 14 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AssignWindowsParDoFn.java (120:133) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/CombineValuesFn.java (157:170) duplicated block id: 20 size: 14 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AssignWindowsParDoFn.java (120:133) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupAlsoByWindowsParDoFn.java (254:267) duplicated block id: 21 size: 14 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ReduceFnContextFactory.java (280:303) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ReduceFnContextFactory.java (333:356) duplicated block id: 22 size: 14 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/CombineValuesFn.java (157:170) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupAlsoByWindowsParDoFn.java (254:267) duplicated block id: 23 size: 14 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/CombineValuesFn.java (83:96) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/NormalParDoFn.java (77:90) duplicated block id: 24 size: 14 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/NormalParDoFn.java (77:90) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ReifyTimestampAndWindowsParDoFn.java (60:73) duplicated block id: 25 size: 13 cleaned lines of code in 2 files: - contrib/join-library/src/main/java/com/google/cloud/dataflow/contrib/joinlibrary/Join.java (52:67) - contrib/join-library/src/main/java/com/google/cloud/dataflow/contrib/joinlibrary/Join.java (154:169) duplicated block id: 26 size: 13 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/DoFnReflector.java (504:524) - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/DoFnReflector.java (563:583) duplicated block id: 27 size: 13 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/Counter.java (534:546) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/Counter.java (849:861) duplicated block id: 28 size: 13 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/BigEndianIntegerCoder.java (59:83) - sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/VarIntCoder.java (62:86) duplicated block id: 29 size: 13 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/WindowedValue.java (233:250) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/WindowedValue.java (278:295) duplicated block id: 30 size: 12 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/TriggerContextFactory.java (285:302) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/TriggerContextFactory.java (346:363) duplicated block id: 31 size: 12 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/TriggerContextFactory.java (346:363) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/TriggerContextFactory.java (396:413) duplicated block id: 32 size: 12 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterProcessingTime.java (66:87) - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterWatermark.java (100:124) duplicated block id: 33 size: 12 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterProcessingTime.java (66:87) - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterSynchronizedProcessingTime.java (45:66) duplicated block id: 34 size: 12 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/io/AvroIO.java (314:329) - sdk/src/main/java/com/google/cloud/dataflow/sdk/io/AvroIO.java (664:679) duplicated block id: 35 size: 12 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/TriggerContextFactory.java (285:302) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/TriggerContextFactory.java (396:413) duplicated block id: 36 size: 12 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/AvroCoder.java (459:474) - sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/AvroCoder.java (605:618) duplicated block id: 37 size: 12 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterSynchronizedProcessingTime.java (45:66) - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterWatermark.java (100:124) duplicated block id: 38 size: 11 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AssignWindowsParDoFn.java (124:134) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ReifyTimestampAndWindowsParDoFn.java (103:113) duplicated block id: 39 size: 11 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/BigEndianLongCoder.java (66:83) - sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/VarLongCoder.java (71:88) duplicated block id: 40 size: 10 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/DefaultParDoFnFactory.java (51:60) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ParDoFnFactory.java (40:49) duplicated block id: 41 size: 10 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AvroReaderFactory.java (41:50) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedShuffleReaderFactory.java (37:46) duplicated block id: 42 size: 10 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/DoFn.java (399:408) - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/DoFnWithContext.java (368:377) duplicated block id: 43 size: 10 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/CombineValuesFn.java (161:170) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ReifyTimestampAndWindowsParDoFn.java (103:112) duplicated block id: 44 size: 10 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/WindmillStateInternals.java (473:485) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/MergedCombiningValue.java (56:68) duplicated block id: 45 size: 10 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ConcatReaderFactory.java (67:76) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedWindmillReader.java (59:68) duplicated block id: 46 size: 10 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupAlsoByWindowsParDoFn.java (258:267) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ReifyTimestampAndWindowsParDoFn.java (103:112) duplicated block id: 47 size: 10 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/InMemoryReaderFactory.java (39:48) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextReaderFactory.java (47:56) duplicated block id: 48 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupingShuffleReaderFactory.java (40:48) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextReaderFactory.java (47:55) duplicated block id: 49 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/DataflowAssert.java (220:233) - sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/DataflowAssert.java (369:382) duplicated block id: 50 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/BigQueryReaderFactory.java (39:47) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PartitioningShuffleReaderFactory.java (40:48) duplicated block id: 51 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupingShuffleReaderFactory.java (40:48) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedShuffleReaderFactory.java (37:45) duplicated block id: 52 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/CustomSources.java (164:172) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedWindmillReader.java (59:67) duplicated block id: 53 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedShuffleReaderFactory.java (37:45) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedWindmillReader.java (59:67) duplicated block id: 54 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/CustomSources.java (164:172) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/InMemoryReaderFactory.java (39:47) duplicated block id: 55 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/BigQueryReaderFactory.java (39:47) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ConcatReaderFactory.java (67:75) duplicated block id: 56 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/InMemoryReaderFactory.java (39:47) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedWindmillReader.java (59:67) duplicated block id: 57 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/CustomSources.java (164:172) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/BigQueryReaderFactory.java (39:47) duplicated block id: 58 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/DoFnRunner.java (77:85) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/DoFnRunner.java (100:108) duplicated block id: 59 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/CustomSources.java (164:172) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupingShuffleReaderFactory.java (40:48) duplicated block id: 60 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ConcatReaderFactory.java (67:75) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedShuffleReaderFactory.java (37:45) duplicated block id: 61 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AvroReaderFactory.java (41:49) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedWindmillReader.java (59:67) duplicated block id: 62 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/BigQueryReaderFactory.java (39:47) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/InMemoryReaderFactory.java (39:47) duplicated block id: 63 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextReaderFactory.java (47:55) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedShuffleReaderFactory.java (37:45) duplicated block id: 64 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupingShuffleReaderFactory.java (40:48) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedWindmillReader.java (59:67) duplicated block id: 65 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AvroReaderFactory.java (41:49) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PartitioningShuffleReaderFactory.java (40:48) duplicated block id: 66 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextSink.java (235:248) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextSink.java (269:282) duplicated block id: 67 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextReaderFactory.java (47:55) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedWindmillReader.java (59:67) duplicated block id: 68 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PartitioningShuffleReaderFactory.java (40:48) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextReaderFactory.java (47:55) duplicated block id: 69 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupingShuffleReaderFactory.java (40:48) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/InMemoryReaderFactory.java (39:47) duplicated block id: 70 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/MergedCombiningValue.java (109:123) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/MergedWatermarkStateInternal.java (88:102) duplicated block id: 71 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/CombineValuesFn.java (88:96) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupAlsoByWindowsParDoFn.java (86:94) duplicated block id: 72 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PartitioningShuffleReaderFactory.java (40:48) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedShuffleReaderFactory.java (37:45) duplicated block id: 73 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/CustomSources.java (164:172) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PartitioningShuffleReaderFactory.java (40:48) duplicated block id: 74 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/InMemoryReaderFactory.java (39:47) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedShuffleReaderFactory.java (37:45) duplicated block id: 75 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AvroReaderFactory.java (41:49) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/InMemoryReaderFactory.java (39:47) duplicated block id: 76 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AssignWindowsParDoFn.java (70:78) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupAlsoByWindowsParDoFn.java (86:94) duplicated block id: 77 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ConcatReaderFactory.java (67:75) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PartitioningShuffleReaderFactory.java (40:48) duplicated block id: 78 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/InMemoryReaderFactory.java (39:47) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PartitioningShuffleReaderFactory.java (40:48) duplicated block id: 79 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/BigQueryReaderFactory.java (39:47) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupingShuffleReaderFactory.java (40:48) duplicated block id: 80 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/BigQueryReaderFactory.java (39:47) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedShuffleReaderFactory.java (37:45) duplicated block id: 81 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/MergedBag.java (79:93) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/MergedWatermarkStateInternal.java (88:102) duplicated block id: 82 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/CustomSources.java (164:172) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ConcatReaderFactory.java (67:75) duplicated block id: 83 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/NormalParDoFn.java (62:70) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/NormalParDoFn.java (139:147) duplicated block id: 84 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/BigQueryReaderFactory.java (39:47) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedWindmillReader.java (59:67) duplicated block id: 85 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ConcatReaderFactory.java (67:75) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/InMemoryReaderFactory.java (39:47) duplicated block id: 86 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AvroReaderFactory.java (41:49) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/BigQueryReaderFactory.java (39:47) duplicated block id: 87 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/CustomCoder.java (81:95) - sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/StandardCoder.java (139:158) duplicated block id: 88 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupAlsoByWindowsParDoFn.java (86:94) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ReifyTimestampAndWindowsParDoFn.java (65:73) duplicated block id: 89 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/CustomSources.java (164:172) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextReaderFactory.java (47:55) duplicated block id: 90 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/CustomSources.java (164:172) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedShuffleReaderFactory.java (37:45) duplicated block id: 91 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AvroReaderFactory.java (41:49) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupingShuffleReaderFactory.java (40:48) duplicated block id: 92 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ConcatReaderFactory.java (67:75) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupingShuffleReaderFactory.java (40:48) duplicated block id: 93 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/CustomSources.java (164:172) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AvroReaderFactory.java (41:49) duplicated block id: 94 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PartitioningShuffleReaderFactory.java (40:48) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedWindmillReader.java (59:67) duplicated block id: 95 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ConcatReaderFactory.java (67:75) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextReaderFactory.java (47:55) duplicated block id: 96 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/BigQueryReaderFactory.java (39:47) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextReaderFactory.java (47:55) duplicated block id: 97 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupingShuffleReaderFactory.java (40:48) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PartitioningShuffleReaderFactory.java (40:48) duplicated block id: 98 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AvroReaderFactory.java (41:49) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextReaderFactory.java (47:55) duplicated block id: 99 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupAlsoByWindowsParDoFn.java (86:94) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/NormalParDoFn.java (82:90) duplicated block id: 100 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AvroReaderFactory.java (41:49) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ConcatReaderFactory.java (67:75) duplicated block id: 101 size: 9 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/MergedBag.java (79:93) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/MergedCombiningValue.java (109:123) duplicated block id: 102 size: 8 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/io/AvroIO.java (159:189) - sdk/src/main/java/com/google/cloud/dataflow/sdk/io/AvroIO.java (418:448) duplicated block id: 103 size: 8 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/SerializableMatchers.java (161:176) - sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/SerializableMatchers.java (231:246) duplicated block id: 104 size: 8 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/SerializableMatchers.java (341:356) - sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/SerializableMatchers.java (411:426) duplicated block id: 105 size: 8 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/DoFnReflector.java (553:564) - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/IntraBundleParallelization.java (268:279) duplicated block id: 106 size: 8 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/ParDo.java (999:1006) - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/Window.java (617:624) duplicated block id: 107 size: 8 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/StringUtf8Coder.java (101:117) - sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/VarLongCoder.java (61:79) duplicated block id: 108 size: 8 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/io/AvroIO.java (691:703) - sdk/src/main/java/com/google/cloud/dataflow/sdk/io/TextIO.java (782:794) duplicated block id: 109 size: 8 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/io/BigQueryIO.java (462:470) - sdk/src/main/java/com/google/cloud/dataflow/sdk/io/TextIO.java (321:329) duplicated block id: 110 size: 8 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PubsubReader.java (55:62) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedWindmillReader.java (62:69) duplicated block id: 111 size: 8 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AssignWindowsParDoFn.java (102:112) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ReifyTimestampAndWindowsParDoFn.java (81:91) duplicated block id: 112 size: 8 cleaned lines of code in 2 files: - contrib/hadoop/src/main/java/com/google/cloud/dataflow/contrib/hadoop/WritableCoder.java (97:106) - sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/SerializableCoder.java (145:154) duplicated block id: 113 size: 8 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/io/BigQueryIO.java (871:879) - sdk/src/main/java/com/google/cloud/dataflow/sdk/io/TextIO.java (705:713) duplicated block id: 114 size: 8 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/MergedBag.java (35:47) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/MergedWatermarkStateInternal.java (35:47) duplicated block id: 115 size: 7 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ConcatReaderFactory.java (70:76) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PubsubReader.java (55:61) duplicated block id: 116 size: 7 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineTranslator.java (483:493) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DirectPipelineRunner.java (685:695) duplicated block id: 117 size: 7 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DirectPipelineRunner.java (359:369) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DirectPipelineRunner.java (907:916) duplicated block id: 118 size: 7 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/AttemptBoundedExponentialBackOff.java (58:68) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/IntervalBoundedExponentialBackOff.java (62:72) duplicated block id: 119 size: 7 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/DoFnRunner.java (101:107) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/DoFnRunner.java (236:242) duplicated block id: 120 size: 7 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AssignWindowsParDoFn.java (102:111) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupAlsoByWindowsParDoFn.java (158:167) duplicated block id: 121 size: 7 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/DoFn.java (74:182) - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/DoFnWithContext.java (86:193) duplicated block id: 122 size: 7 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/CoderRegistry.java (327:335) - sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/CoderRegistry.java (747:755) duplicated block id: 123 size: 7 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedWindmillReader.java (55:63) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/WindowingWindmillReader.java (64:72) duplicated block id: 124 size: 7 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/MapTaskExecutorFactory.java (136:142) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/MapTaskExecutorFactory.java (163:169) duplicated block id: 125 size: 7 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/CombineValuesFn.java (119:128) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ReifyTimestampAndWindowsParDoFn.java (81:90) duplicated block id: 126 size: 7 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/View.java (339:348) - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/View.java (385:394) duplicated block id: 127 size: 7 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextSink.java (91:97) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextSink.java (121:127) duplicated block id: 128 size: 7 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupAlsoByWindowsParDoFn.java (158:167) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ReifyTimestampAndWindowsParDoFn.java (81:90) duplicated block id: 129 size: 7 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/SerializableMatchers.java (723:730) - sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/SerializableMatchers.java (752:759) duplicated block id: 130 size: 7 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PartitioningShuffleReader.java (100:110) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedShuffleReader.java (74:84) duplicated block id: 131 size: 7 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AssignWindowsParDoFn.java (102:111) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/CombineValuesFn.java (119:128) duplicated block id: 132 size: 7 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/Structs.java (205:215) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/Structs.java (229:239) duplicated block id: 133 size: 7 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/NormalParDoFn.java (157:163) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ParDoFnBase.java (80:86) duplicated block id: 134 size: 7 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/WindowedValue.java (634:642) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/WindowedValue.java (708:716) duplicated block id: 135 size: 7 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/DoFnRunner.java (78:84) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/DoFnRunner.java (236:242) duplicated block id: 136 size: 7 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/CombineValuesFn.java (66:72) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/CombineValuesFn.java (154:160) duplicated block id: 137 size: 7 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/CachingSideInputReader.java (56:66) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/DataflowSideInputReader.java (93:109) duplicated block id: 138 size: 7 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/View.java (226:235) - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/View.java (309:318) duplicated block id: 139 size: 7 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/View.java (226:235) - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/View.java (252:261) duplicated block id: 140 size: 7 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/Counter.java (508:518) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/Counter.java (684:694) duplicated block id: 141 size: 7 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/Counter.java (684:694) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/Counter.java (999:1009) duplicated block id: 142 size: 7 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/BigQueryReader.java (136:151) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/Reader.java (185:195) duplicated block id: 143 size: 7 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/View.java (252:261) - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/View.java (309:318) duplicated block id: 144 size: 7 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterWatermark.java (516:526) - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/DefaultTrigger.java (63:73) duplicated block id: 145 size: 7 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/CombineValuesFn.java (119:128) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupAlsoByWindowsParDoFn.java (158:167) duplicated block id: 146 size: 7 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/Counter.java (508:518) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/Counter.java (999:1009) duplicated block id: 147 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/MergedCombiningValue.java (48:56) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/MergedWatermarkStateInternal.java (39:47) duplicated block id: 148 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GroupAlsoByWindowsAndCombineDoFn.java (57:69) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GroupAlsoByWindowsViaIteratorsDoFn.java (60:72) duplicated block id: 149 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/BigQueryReaderFactory.java (42:47) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PubsubReader.java (55:60) duplicated block id: 150 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AssignWindowsParDoFn.java (51:56) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/CombineValuesFn.java (69:74) duplicated block id: 151 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextSink.java (121:126) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextSink.java (139:144) duplicated block id: 152 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/DoFnReflector.java (495:504) - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/DoFnReflector.java (549:558) duplicated block id: 153 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ConcatReaderFactory.java (70:75) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ReaderFactory.java (141:146) duplicated block id: 154 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/PCollectionViews.java (185:191) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/PCollectionViews.java (212:218) duplicated block id: 155 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/Counter.java (625:633) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/Counter.java (940:948) duplicated block id: 156 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineTranslator.java (483:492) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/RecordingPipelineVisitor.java (37:46) duplicated block id: 157 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupingShuffleReaderFactory.java (43:48) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ReaderFactory.java (141:146) duplicated block id: 158 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PartitioningShuffleReaderFactory.java (43:48) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ReaderFactory.java (141:146) duplicated block id: 159 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/TaggedReiteratorList.java (97:106) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/TaggedReiteratorList.java (152:162) duplicated block id: 160 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/io/Read.java (116:123) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRunner.java (546:553) duplicated block id: 161 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/io/PubsubIO.java (340:369) - sdk/src/main/java/com/google/cloud/dataflow/sdk/io/PubsubIO.java (707:733) duplicated block id: 162 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PartitioningShuffleReaderFactory.java (43:48) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PubsubReader.java (55:60) duplicated block id: 163 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AssignWindowsParDoFn.java (51:56) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ReifyTimestampAndWindowsParDoFn.java (45:50) duplicated block id: 164 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PubsubReader.java (55:60) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedShuffleReaderFactory.java (40:45) duplicated block id: 165 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/SourceTestUtils.java (413:418) - sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/SourceTestUtils.java (431:436) duplicated block id: 166 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AssignWindowsParDoFn.java (51:56) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupAlsoByWindowsParDoFn.java (67:72) duplicated block id: 167 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupAlsoByWindowsParDoFn.java (65:70) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupAlsoByWindowsParDoFn.java (252:257) duplicated block id: 168 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/BigQueryReaderFactory.java (42:47) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ReaderFactory.java (141:146) duplicated block id: 169 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterWatermark.java (484:491) - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/DefaultTrigger.java (46:53) duplicated block id: 170 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ReaderFactory.java (141:146) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedWindmillReader.java (62:67) duplicated block id: 171 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/CalendarWindows.java (211:220) - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/CalendarWindows.java (306:315) duplicated block id: 172 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ConcatReader.java (84:89) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ConcatReader.java (126:131) duplicated block id: 173 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/FlatMapElements.java (128:135) - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/MapElements.java (98:105) duplicated block id: 174 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/io/BigQueryIO.java (462:467) - sdk/src/main/java/com/google/cloud/dataflow/sdk/io/BigQueryIO.java (871:876) duplicated block id: 175 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AvroSinkFactory.java (40:45) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextSinkFactory.java (37:42) duplicated block id: 176 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/TriggerContextFactory.java (295:302) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/TriggerContextFactory.java (468:475) duplicated block id: 177 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/AvroIOTranslator.java (104:112) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/TextIOTranslator.java (113:121) duplicated block id: 178 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/io/BigQueryIO.java (871:876) - sdk/src/main/java/com/google/cloud/dataflow/sdk/io/TextIO.java (321:326) duplicated block id: 179 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/InMemoryReaderFactory.java (42:47) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PubsubReader.java (55:60) duplicated block id: 180 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRunner.java (772:778) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRunner.java (803:809) duplicated block id: 181 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AvroReaderFactory.java (44:49) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ReaderFactory.java (141:146) duplicated block id: 182 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PubsubSink.java (90:97) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/WindmillSink.java (109:116) duplicated block id: 183 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/Counter.java (657:665) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/Counter.java (972:980) duplicated block id: 184 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextSink.java (91:96) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextSink.java (139:144) duplicated block id: 185 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/io/Read.java (202:209) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRunner.java (546:553) duplicated block id: 186 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/DataflowAssert.java (569:575) - sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/DataflowAssert.java (642:648) duplicated block id: 187 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextSink.java (99:104) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextSink.java (129:134) duplicated block id: 188 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/PartialGroupByKeyOperation.java (151:156) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/PartialGroupByKeyOperation.java (173:178) duplicated block id: 189 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/CalendarWindows.java (125:134) - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/CalendarWindows.java (306:315) duplicated block id: 190 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/Counter.java (458:466) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/Counter.java (625:633) duplicated block id: 191 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ReaderFactory.java (141:146) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedShuffleReaderFactory.java (40:45) duplicated block id: 192 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PubsubReader.java (55:60) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ReaderFactory.java (141:146) duplicated block id: 193 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/io/Read.java (116:123) - sdk/src/main/java/com/google/cloud/dataflow/sdk/io/Read.java (202:209) duplicated block id: 194 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/Counter.java (549:557) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/Counter.java (864:872) duplicated block id: 195 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/FlattenOperation.java (26:31) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/ReceivingOperation.java (38:43) duplicated block id: 196 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/CombineValuesFn.java (69:74) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupAlsoByWindowsParDoFn.java (67:72) duplicated block id: 197 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ConcatReader.java (77:82) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ConcatReader.java (120:125) duplicated block id: 198 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/io/TextIO.java (321:326) - sdk/src/main/java/com/google/cloud/dataflow/sdk/io/TextIO.java (705:710) duplicated block id: 199 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/InMemoryReaderFactory.java (42:47) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ReaderFactory.java (141:146) duplicated block id: 200 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/BigEndianLongCoder.java (59:74) - sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/VarIntCoder.java (62:77) duplicated block id: 201 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupAlsoByWindowsParDoFn.java (67:72) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ReifyTimestampAndWindowsParDoFn.java (45:50) duplicated block id: 202 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/CombineValuesFn.java (69:74) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ReifyTimestampAndWindowsParDoFn.java (45:50) duplicated block id: 203 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/Counter.java (458:466) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/Counter.java (940:948) duplicated block id: 204 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/MergedBag.java (39:47) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/MergedCombiningValue.java (48:56) duplicated block id: 205 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterWatermark.java (253:262) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ReshuffleTrigger.java (50:59) duplicated block id: 206 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ReaderFactory.java (141:146) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextReaderFactory.java (50:55) duplicated block id: 207 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AvroReaderFactory.java (44:49) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PubsubReader.java (55:60) duplicated block id: 208 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/NormalParDoFn.java (52:57) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/NormalParDoFn.java (155:160) duplicated block id: 209 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupingShuffleReaderFactory.java (43:48) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PubsubReader.java (55:60) duplicated block id: 210 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/StateNamespaces.java (104:112) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/StateNamespaces.java (169:177) duplicated block id: 211 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/DefaultParDoFnFactory.java (49:54) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupAlsoByWindowsParDoFn.java (82:87) duplicated block id: 212 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/CalendarWindows.java (195:202) - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/CalendarWindows.java (289:296) duplicated block id: 213 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/io/FileBasedSink.java (599:604) - sdk/src/main/java/com/google/cloud/dataflow/sdk/io/FileBasedSink.java (663:668) duplicated block id: 214 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/CustomSources.java (167:172) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ReaderFactory.java (141:146) duplicated block id: 215 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/BigEndianIntegerCoder.java (59:74) - sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/BigEndianLongCoder.java (59:74) duplicated block id: 216 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/dataflow/CustomSources.java (167:172) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PubsubReader.java (55:60) duplicated block id: 217 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/CalendarWindows.java (125:134) - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/CalendarWindows.java (211:220) duplicated block id: 218 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/TriggerContextFactory.java (356:363) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/TriggerContextFactory.java (468:475) duplicated block id: 219 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AssignWindowsParDoFn.java (49:54) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AssignWindowsParDoFn.java (118:123) duplicated block id: 220 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/io/BigQueryIO.java (462:467) - sdk/src/main/java/com/google/cloud/dataflow/sdk/io/TextIO.java (705:710) duplicated block id: 221 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DirectPipelineRunner.java (685:694) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/RecordingPipelineVisitor.java (37:46) duplicated block id: 222 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/TriggerContextFactory.java (406:413) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/TriggerContextFactory.java (468:475) duplicated block id: 223 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/MapTaskExecutorFactory.java (147:152) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/MapTaskExecutorFactory.java (175:180) duplicated block id: 224 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PubsubReader.java (54:59) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ReaderFactory.java (48:53) duplicated block id: 225 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterProcessingTime.java (58:63) - sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterSynchronizedProcessingTime.java (37:42) duplicated block id: 226 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ParDoFnBase.java (195:200) - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/DoFnRunner.java (90:95) duplicated block id: 227 size: 6 cleaned lines of code in 2 files: - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/PubsubReader.java (55:60) - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextReaderFactory.java (50:55)