duplicated block id: 1 size: 44 cleaned lines of code in 2 files: - sdks/java/harness/src/main/java/org/apache/beam/fn/harness/status/MemoryMonitor.java (475:534) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/MemoryMonitor.java (475:534) duplicated block id: 2 size: 42 cleaned lines of code in 2 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/ShardReadersPool.java (130:181) - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/ShardReadersPool.java (130:181) duplicated block id: 3 size: 39 cleaned lines of code in 2 files: - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/BeamFnMapTaskExecutorFactory.java (553:594) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IntrinsicMapTaskExecutorFactory.java (160:201) duplicated block id: 4 size: 39 cleaned lines of code in 2 files: - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/BeamFnMapTaskExecutorFactory.java (677:722) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IntrinsicMapTaskExecutorFactory.java (284:329) duplicated block id: 5 size: 36 cleaned lines of code in 2 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/KinesisReader.java (171:212) - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/KinesisReader.java (171:212) duplicated block id: 6 size: 30 cleaned lines of code in 2 files: - sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/POJOUtils.java (190:222) - sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/JavaBeanUtils.java (273:304) duplicated block id: 7 size: 30 cleaned lines of code in 2 files: - sdks/java/harness/src/main/java/org/apache/beam/fn/harness/PrecombineGroupingTable.java (328:364) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/GroupingTables.java (359:395) duplicated block id: 8 size: 30 cleaned lines of code in 2 files: - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/BeamFnMapTaskExecutorFactory.java (637:671) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IntrinsicMapTaskExecutorFactory.java (244:278) duplicated block id: 9 size: 27 cleaned lines of code in 2 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/ShardCheckpoint.java (79:108) - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/ShardCheckpoint.java (79:108) duplicated block id: 10 size: 25 cleaned lines of code in 2 files: - sdks/java/harness/src/main/java/org/apache/beam/fn/harness/PrecombineGroupingTable.java (380:408) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/GroupingTables.java (226:254) duplicated block id: 11 size: 23 cleaned lines of code in 2 files: - sdks/java/harness/src/main/java/org/apache/beam/fn/harness/status/MemoryMonitor.java (537:562) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/MemoryMonitor.java (537:562) duplicated block id: 12 size: 23 cleaned lines of code in 2 files: - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/BeamFnMapTaskExecutorFactory.java (733:759) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IntrinsicMapTaskExecutorFactory.java (340:366) duplicated block id: 13 size: 21 cleaned lines of code in 2 files: - sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/OrderedCode.java (302:326) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/OrderedCode.java (257:281) duplicated block id: 14 size: 21 cleaned lines of code in 2 files: - runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/functions/GroupAlsoByWindowViaOutputBufferFn.java (122:144) - runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkGroupAlsoByWindowViaOutputBufferFn.java (115:137) duplicated block id: 15 size: 20 cleaned lines of code in 2 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/StartingPointShardsFinder.java (109:131) - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/StartingPointShardsFinder.java (109:131) duplicated block id: 16 size: 18 cleaned lines of code in 2 files: - sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/SqlTransformRunner.java (118:139) - sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/BeamSqlEnvRunner.java (129:149) duplicated block id: 17 size: 17 cleaned lines of code in 2 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/KinesisRecordCoder.java (57:75) - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/KinesisRecordCoder.java (57:75) duplicated block id: 18 size: 17 cleaned lines of code in 2 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/KinesisSource.java (69:87) - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/KinesisSource.java (69:87) duplicated block id: 19 size: 17 cleaned lines of code in 2 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/KinesisSource.java (94:114) - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/KinesisSource.java (94:114) duplicated block id: 20 size: 17 cleaned lines of code in 2 files: - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/BeamFnMapTaskExecutorFactory.java (596:616) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IntrinsicMapTaskExecutorFactory.java (203:223) duplicated block id: 21 size: 17 cleaned lines of code in 2 files: - runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/metrics/WithMetricsSupport.java (98:123) - runners/spark/src/main/java/org/apache/beam/runners/spark/metrics/WithMetricsSupport.java (98:123) duplicated block id: 22 size: 17 cleaned lines of code in 2 files: - runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/SparkTransformOverrides.java (35:54) - runners/spark/src/main/java/org/apache/beam/runners/spark/SparkTransformOverrides.java (35:54) duplicated block id: 23 size: 16 cleaned lines of code in 2 files: - sdks/go/pkg/beam/io/textio/textio.go (61:80) - sdks/go/pkg/beam/io/avroio/avroio.go (57:76) duplicated block id: 24 size: 16 cleaned lines of code in 2 files: - sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Trigger.java (155:175) - runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachine.java (354:374) duplicated block id: 25 size: 16 cleaned lines of code in 2 files: - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/s3/S3WritableByteChannel.java (120:141) - sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/s3/S3WritableByteChannel.java (114:135) duplicated block id: 26 size: 16 cleaned lines of code in 2 files: - sdks/java/harness/src/main/java/org/apache/beam/fn/harness/status/MemoryMonitor.java (254:272) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/MemoryMonitor.java (254:272) duplicated block id: 27 size: 16 cleaned lines of code in 2 files: - sdks/java/harness/src/main/java/org/apache/beam/fn/harness/status/MemoryMonitor.java (276:294) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/MemoryMonitor.java (276:294) duplicated block id: 28 size: 16 cleaned lines of code in 2 files: - runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/metrics/SparkBeamMetric.java (67:88) - runners/spark/src/main/java/org/apache/beam/runners/spark/metrics/SparkBeamMetric.java (81:102) duplicated block id: 29 size: 15 cleaned lines of code in 2 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/ShardRecordsIterator.java (76:93) - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/ShardRecordsIterator.java (76:93) duplicated block id: 30 size: 15 cleaned lines of code in 2 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/GetKinesisRecordsResult.java (31:47) - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/GetKinesisRecordsResult.java (31:47) duplicated block id: 31 size: 15 cleaned lines of code in 2 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/ShardReadersPool.java (215:232) - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/ShardReadersPool.java (215:232) duplicated block id: 32 size: 15 cleaned lines of code in 2 files: - learning/katas/java/Windowing/Adding Timestamp/WithTimestamps/src/org/apache/beam/learning/katas/windowing/addingtimestamp/withtimestamps/Task.java (32:52) - learning/katas/java/Windowing/Adding Timestamp/ParDo/src/org/apache/beam/learning/katas/windowing/addingtimestamp/pardo/Task.java (33:53) duplicated block id: 33 size: 14 cleaned lines of code in 2 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/KinesisSource.java (122:141) - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/KinesisSource.java (122:141) duplicated block id: 34 size: 14 cleaned lines of code in 2 files: - learning/katas/kotlin/Windowing/Adding Timestamp/WithTimestamps/src/org/apache/beam/learning/katas/windowing/addingtimestamp/withtimestamps/Task.kt (30:49) - learning/katas/kotlin/Windowing/Adding Timestamp/ParDo/src/org/apache/beam/learning/katas/windowing/addingtimestamp/pardo/Task.kt (31:50) duplicated block id: 35 size: 14 cleaned lines of code in 2 files: - runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/FnApiControlClientPoolService.java (116:131) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/fn/BeamFnControlService.java (104:119) duplicated block id: 36 size: 14 cleaned lines of code in 2 files: - runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SplittableParDoProcessKeyedElementsOp.java (222:239) - runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/GroupByKeyOp.java (199:216) duplicated block id: 37 size: 13 cleaned lines of code in 2 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/ShardRecordsIterator.java (95:109) - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/ShardRecordsIterator.java (95:109) duplicated block id: 38 size: 13 cleaned lines of code in 2 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/ShardReadersPool.java (307:322) - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/ShardReadersPool.java (307:322) duplicated block id: 39 size: 13 cleaned lines of code in 2 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/ShardReadersPool.java (324:338) - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/ShardReadersPool.java (324:338) duplicated block id: 40 size: 13 cleaned lines of code in 2 files: - sdks/java/harness/src/main/java/org/apache/beam/fn/harness/status/MemoryMonitor.java (620:634) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/MemoryMonitor.java (625:639) duplicated block id: 41 size: 13 cleaned lines of code in 2 files: - runners/core-java/src/main/java/org/apache/beam/runners/core/ProcessFnRunner.java (97:112) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowProcessFnRunner.java (79:94) duplicated block id: 42 size: 13 cleaned lines of code in 2 files: - runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SamzaTestStreamSystemFactory.java (95:110) - runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SamzaImpulseSystemFactory.java (79:94) duplicated block id: 43 size: 13 cleaned lines of code in 2 files: - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingModeExecutionContext.java (611:625) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/BatchModeExecutionContext.java (408:422) duplicated block id: 44 size: 13 cleaned lines of code in 2 files: - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/BeamFnMapTaskExecutorFactory.java (618:633) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IntrinsicMapTaskExecutorFactory.java (225:240) duplicated block id: 45 size: 12 cleaned lines of code in 3 files: - sdks/java/core/src/main/java/org/apache/beam/sdk/util/ExplicitShardedFile.java (115:128) - sdks/java/core/src/main/java/org/apache/beam/sdk/util/FilePatternMatchingShardedFile.java (130:143) - sdks/java/core/src/main/java/org/apache/beam/sdk/util/NumberedShardedFile.java (165:178) duplicated block id: 46 size: 12 cleaned lines of code in 2 files: - sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/POJOUtils.java (175:188) - sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/JavaBeanUtils.java (258:271) duplicated block id: 47 size: 12 cleaned lines of code in 2 files: - sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/POJOUtils.java (332:346) - sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/JavaBeanUtils.java (199:212) duplicated block id: 48 size: 12 cleaned lines of code in 2 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/WatermarkPolicyFactory.java (108:123) - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/WatermarkPolicyFactory.java (108:123) duplicated block id: 49 size: 12 cleaned lines of code in 2 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/ShardReadersPool.java (103:118) - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/ShardReadersPool.java (103:118) duplicated block id: 50 size: 12 cleaned lines of code in 2 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/ShardReadersPool.java (183:199) - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/ShardReadersPool.java (183:199) duplicated block id: 51 size: 12 cleaned lines of code in 2 files: - sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/OrderedCode.java (238:254) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/OrderedCode.java (216:232) duplicated block id: 52 size: 12 cleaned lines of code in 2 files: - sdks/java/harness/src/main/java/org/apache/beam/fn/harness/status/MemoryMonitor.java (359:377) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/MemoryMonitor.java (359:377) duplicated block id: 53 size: 12 cleaned lines of code in 2 files: - runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/SparkStructuredStreamingPipelineResult.java (119:135) - runners/spark/src/main/java/org/apache/beam/runners/spark/SparkPipelineResult.java (96:111) duplicated block id: 54 size: 11 cleaned lines of code in 2 files: - sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/OffsetRangeTracker.java (210:223) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/GroupingShuffleRangeTracker.java (84:97) duplicated block id: 55 size: 11 cleaned lines of code in 2 files: - sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/POJOUtils.java (224:236) - sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/JavaBeanUtils.java (306:318) duplicated block id: 56 size: 11 cleaned lines of code in 2 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/ShardReadersPool.java (201:213) - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/ShardReadersPool.java (201:213) duplicated block id: 57 size: 11 cleaned lines of code in 2 files: - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/s3/S3FileSystem.java (623:635) - sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/s3/S3FileSystem.java (596:608) duplicated block id: 58 size: 11 cleaned lines of code in 2 files: - sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/Transport.java (76:88) - runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/DataflowTransport.java (49:61) duplicated block id: 59 size: 11 cleaned lines of code in 2 files: - sdks/java/harness/src/main/java/org/apache/beam/fn/harness/status/MemoryMonitor.java (380:392) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/MemoryMonitor.java (380:392) duplicated block id: 60 size: 11 cleaned lines of code in 2 files: - learning/katas/java/Core Transforms/Combine/BinaryCombineFn Lambda/src/org/apache/beam/learning/katas/coretransforms/combine/binarycombinefnlambda/Task.java (32:48) - learning/katas/java/Core Transforms/Combine/BinaryCombineFn/src/org/apache/beam/learning/katas/coretransforms/combine/binarycombinefn/Task.java (33:49) duplicated block id: 61 size: 11 cleaned lines of code in 2 files: - learning/katas/kotlin/Core Transforms/Combine/BinaryCombineFn Lambda/src/org/apache/beam/learning/katas/coretransforms/combine/binarycombinefnlambda/Task.kt (30:46) - learning/katas/kotlin/Core Transforms/Combine/BinaryCombineFn/src/org/apache/beam/learning/katas/coretransforms/combine/binarycombinefn/Task.kt (31:47) duplicated block id: 62 size: 11 cleaned lines of code in 2 files: - runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/SparkStructuredStreamingRunner.java (202:215) - runners/spark/src/main/java/org/apache/beam/runners/spark/SparkRunner.java (273:286) duplicated block id: 63 size: 10 cleaned lines of code in 2 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/WatermarkPolicyFactory.java (126:137) - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/WatermarkPolicyFactory.java (126:137) duplicated block id: 64 size: 10 cleaned lines of code in 2 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/ShardReadersPool.java (249:260) - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/ShardReadersPool.java (249:260) duplicated block id: 65 size: 10 cleaned lines of code in 2 files: - sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWritesShardedRecords.java (140:151) - sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWriteUnshardedRecords.java (78:89) duplicated block id: 66 size: 10 cleaned lines of code in 2 files: - learning/katas/java/Windowing/Adding Timestamp/WithTimestamps/src/org/apache/beam/learning/katas/windowing/addingtimestamp/withtimestamps/Event.java (62:76) - learning/katas/java/Windowing/Adding Timestamp/ParDo/src/org/apache/beam/learning/katas/windowing/addingtimestamp/pardo/Event.java (62:76) duplicated block id: 67 size: 10 cleaned lines of code in 2 files: - runners/jet/src/main/java/org/apache/beam/runners/jet/processors/WindowGroupP.java (197:208) - runners/core-java/src/main/java/org/apache/beam/runners/core/TestInMemoryStateInternals.java (52:63) duplicated block id: 68 size: 10 cleaned lines of code in 2 files: - runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/ExecutableStageDoFnOperator.java (297:308) - runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkExecutableStageFunction.java (185:196) duplicated block id: 69 size: 10 cleaned lines of code in 2 files: - runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkReduceFunction.java (66:77) - runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkPartialReduceFunction.java (66:77) duplicated block id: 70 size: 9 cleaned lines of code in 2 files: - sdks/go/pkg/beam/testing/passert/passert.shims.go (549:559) - sdks/go/pkg/beam/x/debug/debug.shims.go (339:349) duplicated block id: 71 size: 9 cleaned lines of code in 2 files: - sdks/go/pkg/beam/testing/passert/passert.shims.go (567:577) - sdks/go/pkg/beam/x/debug/debug.shims.go (376:386) duplicated block id: 72 size: 9 cleaned lines of code in 2 files: - sdks/java/core/src/main/java/org/apache/beam/sdk/io/TextSource.java (235:249) - sdks/java/io/contextualtextio/src/main/java/org/apache/beam/sdk/io/contextualtextio/ContextualTextIOSource.java (290:305) duplicated block id: 73 size: 9 cleaned lines of code in 2 files: - sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/MapElements.java (295:305) - sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/FlatMapElements.java (312:322) duplicated block id: 74 size: 9 cleaned lines of code in 2 files: - sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Trigger.java (178:188) - runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachine.java (377:387) duplicated block id: 75 size: 9 cleaned lines of code in 3 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/BasicKinesisProvider.java (84:94) - sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sns/BasicSnsProvider.java (57:67) - sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/dynamodb/BasicDynamoDBProvider.java (56:66) duplicated block id: 76 size: 9 cleaned lines of code in 2 files: - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/s3/S3ResourceId.java (70:80) - sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/s3/S3ResourceId.java (70:80) duplicated block id: 77 size: 9 cleaned lines of code in 2 files: - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/s3/S3WritableByteChannel.java (205:215) - sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/s3/S3WritableByteChannel.java (188:198) duplicated block id: 78 size: 9 cleaned lines of code in 2 files: - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/SnsIO.java (157:167) - sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sns/SnsIO.java (125:135) duplicated block id: 79 size: 9 cleaned lines of code in 3 files: - sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/RightJoin.java (145:155) - sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/LeftJoin.java (144:154) - sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/FullJoin.java (145:155) duplicated block id: 80 size: 9 cleaned lines of code in 2 files: - sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigquery/BigQueryFilter.java (94:105) - sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/mongodb/MongoDbTable.java (393:404) duplicated block id: 81 size: 9 cleaned lines of code in 7 files: - learning/katas/go/common_transforms/aggregation/mean/cmd/main.go (27:43) - learning/katas/go/common_transforms/aggregation/count/cmd/main.go (27:43) - learning/katas/go/common_transforms/aggregation/max/cmd/main.go (27:43) - learning/katas/go/common_transforms/aggregation/sum/cmd/main.go (27:43) - learning/katas/go/common_transforms/aggregation/min/cmd/main.go (27:43) - learning/katas/go/common_transforms/filter/pardo/cmd/main.go (27:43) - learning/katas/go/common_transforms/filter/filter/cmd/main.go (27:43) duplicated block id: 82 size: 9 cleaned lines of code in 2 files: - runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/HashingFlinkCombineRunner.java (171:181) - runners/core-java/src/main/java/org/apache/beam/runners/core/ReduceFnRunner.java (389:399) duplicated block id: 83 size: 9 cleaned lines of code in 2 files: - runners/samza/src/main/java/org/apache/beam/runners/samza/adapter/UnboundedSourceSystem.java (427:441) - runners/samza/src/main/java/org/apache/beam/runners/samza/adapter/BoundedSourceSystem.java (388:402) duplicated block id: 84 size: 9 cleaned lines of code in 2 files: - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingKeyedWorkItemSideInputDoFnRunner.java (138:148) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingSideInputDoFnRunner.java (79:89) duplicated block id: 85 size: 9 cleaned lines of code in 2 files: - runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/functions/ByteToWindowFunctionPrimitive.java (97:108) - runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/functions/ByteToWindowFunction.java (93:104) duplicated block id: 86 size: 9 cleaned lines of code in 2 files: - runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java (79:89) - runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java (79:89) duplicated block id: 87 size: 9 cleaned lines of code in 2 files: - runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/SparkStructuredStreamingPipelineResult.java (65:80) - runners/spark/src/main/java/org/apache/beam/runners/spark/SparkPipelineResult.java (63:78) duplicated block id: 88 size: 8 cleaned lines of code in 2 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/StartingPoint.java (65:74) - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/StartingPoint.java (65:74) duplicated block id: 89 size: 8 cleaned lines of code in 2 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/KinesisReader.java (96:107) - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/KinesisReader.java (96:107) duplicated block id: 90 size: 8 cleaned lines of code in 2 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/ShardCheckpoint.java (118:127) - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/ShardCheckpoint.java (118:127) duplicated block id: 91 size: 8 cleaned lines of code in 2 files: - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/dynamodb/DynamoDBIO.java (495:504) - sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/dynamodb/DynamoDBIO.java (477:486) duplicated block id: 92 size: 8 cleaned lines of code in 2 files: - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/SqsCheckpointMark.java (50:59) - sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sqs/SqsCheckpointMark.java (51:60) duplicated block id: 93 size: 8 cleaned lines of code in 3 files: - sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/TestBigQuery.java (325:334) - sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/options/GcpOptions.java (450:459) - sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/Transport.java (115:124) duplicated block id: 94 size: 8 cleaned lines of code in 2 files: - sdks/java/expansion-service/src/main/java/org/apache/beam/sdk/expansion/service/ExpansionServer.java (69:79) - runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/GrpcFnServer.java (152:162) duplicated block id: 95 size: 8 cleaned lines of code in 2 files: - sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ByteStringCoder.java (57:68) - runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/wire/ByteStringCoder.java (58:69) duplicated block id: 96 size: 8 cleaned lines of code in 3 files: - sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamCoGBKJoinRel.java (77:86) - sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamSideInputJoinRel.java (71:80) - sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamSideInputLookupJoinRel.java (63:72) duplicated block id: 97 size: 8 cleaned lines of code in 2 files: - sdks/java/harness/src/main/java/org/apache/beam/fn/harness/status/MemoryMonitor.java (461:471) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/MemoryMonitor.java (461:471) duplicated block id: 98 size: 8 cleaned lines of code in 2 files: - sdks/java/harness/src/main/java/org/apache/beam/fn/harness/status/BeamFnStatusClient.java (88:97) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/status/ThreadzServlet.java (63:72) duplicated block id: 99 size: 8 cleaned lines of code in 2 files: - learning/katas/kotlin/Common Transforms/WithKeys/WithKeys/src/org/apache/beam/learning/katas/commontransforms/withkeys/Task.kt (31:44) - learning/katas/kotlin/Core Transforms/GroupByKey/GroupByKey/src/org/apache/beam/learning/katas/coretransforms/groupbykey/Task.kt (33:46) duplicated block id: 100 size: 8 cleaned lines of code in 2 files: - runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/logging/GrpcLoggingService.java (53:67) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/fn/logging/BeamFnLoggingService.java (79:93) duplicated block id: 101 size: 8 cleaned lines of code in 3 files: - runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/ExecutableStageDoFnOperator.java (571:580) - runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java (1420:1429) - runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java (232:241) duplicated block id: 102 size: 8 cleaned lines of code in 2 files: - runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/HashingFlinkCombineRunner.java (133:145) - runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/AggregatorCombiner.java (233:245) duplicated block id: 103 size: 8 cleaned lines of code in 2 files: - runners/core-java/src/main/java/org/apache/beam/runners/core/ProcessFnRunner.java (86:95) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowProcessFnRunner.java (112:121) duplicated block id: 104 size: 8 cleaned lines of code in 2 files: - runners/samza/src/main/java/org/apache/beam/runners/samza/adapter/UnboundedSourceSystem.java (414:425) - runners/samza/src/main/java/org/apache/beam/runners/samza/adapter/BoundedSourceSystem.java (328:339) duplicated block id: 105 size: 8 cleaned lines of code in 2 files: - runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java (62:71) - runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java (62:71) duplicated block id: 106 size: 8 cleaned lines of code in 2 files: - runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/functions/GroupAlsoByWindowViaOutputBufferFn.java (55:64) - runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkGroupAlsoByWindowViaOutputBufferFn.java (56:65) duplicated block id: 107 size: 7 cleaned lines of code in 2 files: - sdks/java/core/src/main/java/org/apache/beam/sdk/io/TextSource.java (269:280) - sdks/java/io/contextualtextio/src/main/java/org/apache/beam/sdk/io/contextualtextio/ContextualTextIOSource.java (342:353) duplicated block id: 108 size: 7 cleaned lines of code in 2 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/ShardCheckpoint.java (144:152) - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/ShardCheckpoint.java (144:152) duplicated block id: 109 size: 7 cleaned lines of code in 2 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/DynamicCheckpointGenerator.java (45:53) - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/DynamicCheckpointGenerator.java (45:53) duplicated block id: 110 size: 7 cleaned lines of code in 2 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/RecordFilter.java (32:40) - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/RecordFilter.java (32:40) duplicated block id: 111 size: 7 cleaned lines of code in 2 files: - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/s3/S3ResourceId.java (53:61) - sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/s3/S3ResourceId.java (53:61) duplicated block id: 112 size: 7 cleaned lines of code in 2 files: - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/SqsUnboundedReader.java (51:61) - sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sqs/SqsUnboundedReader.java (50:60) duplicated block id: 113 size: 7 cleaned lines of code in 2 files: - sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWritesShardedRecords.java (129:138) - sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWriteUnshardedRecords.java (120:129) duplicated block id: 114 size: 7 cleaned lines of code in 3 files: - sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/RightJoin.java (95:104) - sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/LeftJoin.java (94:103) - sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/FullJoin.java (95:104) duplicated block id: 115 size: 7 cleaned lines of code in 2 files: - sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/unnest/BeamZetaSqlUnnestRel.java (82:90) - sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamUnnestRel.java (75:83) duplicated block id: 116 size: 7 cleaned lines of code in 2 files: - sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/ScalarFunctionImpl.java (239:247) - sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/UdfImplReflectiveFunctionBase.java (70:78) duplicated block id: 117 size: 7 cleaned lines of code in 2 files: - sdks/java/harness/src/main/java/org/apache/beam/fn/harness/status/MemoryMonitor.java (333:341) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/MemoryMonitor.java (333:341) duplicated block id: 118 size: 7 cleaned lines of code in 3 files: - learning/katas/java/Triggers/Early Triggers/Early Triggers/src/org/apache/beam/learning/katas/triggers/earlytriggers/Task.java (36:48) - learning/katas/java/Triggers/Window Accumulation Mode/Window Accumulation Mode/src/org/apache/beam/learning/katas/triggers/windowaccummode/Task.java (36:48) - learning/katas/java/Triggers/Event Time Triggers/Event Time Triggers/src/org/apache/beam/learning/katas/triggers/eventtimetriggers/Task.java (35:47) duplicated block id: 119 size: 7 cleaned lines of code in 2 files: - learning/katas/java/Core Transforms/Map/ParDo OneToMany/src/org/apache/beam/learning/katas/coretransforms/map/pardoonetomany/Task.java (32:44) - learning/katas/java/Core Transforms/Map/FlatMapElements/src/org/apache/beam/learning/katas/coretransforms/map/flatmapelements/Task.java (33:45) duplicated block id: 120 size: 7 cleaned lines of code in 2 files: - buildSrc/src/main/groovy/org/apache/beam/gradle/GrpcVendoring_1_26_0.groovy (88:97) - buildSrc/src/main/groovy/org/apache/beam/gradle/GrpcVendoring_1_36_0.groovy (67:76) duplicated block id: 121 size: 7 cleaned lines of code in 2 files: - runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/logging/GrpcLoggingService.java (78:87) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/fn/logging/BeamFnLoggingService.java (104:113) duplicated block id: 122 size: 7 cleaned lines of code in 2 files: - runners/core-java/src/main/java/org/apache/beam/runners/core/ProcessFnRunner.java (114:127) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowProcessFnRunner.java (96:109) duplicated block id: 123 size: 7 cleaned lines of code in 5 files: - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ToIsmRecordForMultimapDoFnFactory.java (91:99) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/CreateIsmShardKeyAndSortKeyDoFnFactory.java (86:94) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ValuesDoFnFactory.java (62:70) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ReifyTimestampAndWindowsParDoFnFactory.java (58:66) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/PairWithConstantKeyDoFnFactory.java (81:89) duplicated block id: 124 size: 7 cleaned lines of code in 2 files: - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorker.java (228:236) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WorkItemStatusClient.java (184:192) duplicated block id: 125 size: 7 cleaned lines of code in 2 files: - runners/twister2/src/main/java/org/apache/beam/runners/twister2/translation/wrappers/Twister2BoundedSource.java (228:236) - runners/spark/src/main/java/org/apache/beam/runners/spark/io/SourceRDD.java (223:231) duplicated block id: 126 size: 6 cleaned lines of code in 4 files: - sdks/go/pkg/beam/core/runtime/exec/input.go (129:136) - sdks/go/pkg/beam/util/shimx/generate.go (364:371) - sdks/go/pkg/beam/testing/passert/passert.shims.go (486:493) - sdks/go/pkg/beam/x/debug/debug.shims.go (312:319) duplicated block id: 127 size: 6 cleaned lines of code in 2 files: - sdks/java/core/src/main/java/org/apache/beam/sdk/io/Read.java (584:591) - sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/ReadFromKafkaDoFn.java (449:456) duplicated block id: 128 size: 6 cleaned lines of code in 2 files: - sdks/java/core/src/main/java/org/apache/beam/sdk/io/TextIO.java (389:397) - sdks/java/io/contextualtextio/src/main/java/org/apache/beam/sdk/io/contextualtextio/ContextualTextIO.java (371:379) duplicated block id: 129 size: 6 cleaned lines of code in 2 files: - sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollectionViews.java (1271:1278) - runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/RunnerPCollectionView.java (100:107) duplicated block id: 130 size: 6 cleaned lines of code in 2 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/KinesisReader.java (214:221) - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/KinesisReader.java (214:221) duplicated block id: 131 size: 6 cleaned lines of code in 2 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/ShardCheckpoint.java (70:77) - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/ShardCheckpoint.java (70:77) duplicated block id: 132 size: 6 cleaned lines of code in 2 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/ShardCheckpoint.java (164:171) - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/ShardCheckpoint.java (164:171) duplicated block id: 133 size: 6 cleaned lines of code in 2 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/KinesisReaderCheckpoint.java (50:58) - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/KinesisReaderCheckpoint.java (50:58) duplicated block id: 134 size: 6 cleaned lines of code in 2 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/ShardReadersPool.java (273:282) - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/ShardReadersPool.java (273:282) duplicated block id: 135 size: 6 cleaned lines of code in 2 files: - sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/WatermarkParameters.java (50:57) - sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/WatermarkParameters.java (50:57) duplicated block id: 136 size: 6 cleaned lines of code in 2 files: - sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/ProducerRecordCoder.java (92:101) - sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaRecordCoder.java (85:94) duplicated block id: 137 size: 6 cleaned lines of code in 4 files: - sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/Join.java (201:208) - sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/RightJoin.java (135:142) - sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/LeftJoin.java (134:141) - sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/FullJoin.java (135:142) duplicated block id: 138 size: 6 cleaned lines of code in 2 files: - sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/ReduceWindow.java (213:220) - sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/ReduceByKey.java (262:269) duplicated block id: 139 size: 6 cleaned lines of code in 3 files: - sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/ReduceWindow.java (409:416) - sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/TopPerKey.java (254:261) - sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/ReduceByKey.java (509:516) duplicated block id: 140 size: 6 cleaned lines of code in 4 files: - sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/CountByKey.java (188:195) - sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/TopPerKey.java (244:251) - sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/SumByKey.java (209:216) - sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/ReduceByKey.java (499:506) duplicated block id: 141 size: 6 cleaned lines of code in 2 files: - sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/UdfImpl.java (72:79) - sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/UdfImplReflectiveFunctionBase.java (87:94) duplicated block id: 142 size: 6 cleaned lines of code in 2 files: - sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/text/TextTableProvider.java (284:291) - sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/CsvToRow.java (49:56) duplicated block id: 143 size: 6 cleaned lines of code in 2 files: - sdks/java/harness/src/main/java/org/apache/beam/fn/harness/PrecombineGroupingTable.java (227:234) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/PartialGroupByKeyParDoFns.java (158:165) duplicated block id: 144 size: 6 cleaned lines of code in 2 files: - sdks/java/harness/src/main/java/org/apache/beam/fn/harness/PrecombineGroupingTable.java (440:448) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/GroupingTables.java (399:407) duplicated block id: 145 size: 6 cleaned lines of code in 2 files: - sdks/java/harness/src/main/java/org/apache/beam/fn/harness/status/MemoryMonitor.java (401:417) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/MemoryMonitor.java (401:417) duplicated block id: 146 size: 6 cleaned lines of code in 2 files: - sdks/java/harness/src/main/java/org/apache/beam/fn/harness/status/MemoryMonitor.java (425:434) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/MemoryMonitor.java (425:434) duplicated block id: 147 size: 6 cleaned lines of code in 6 files: - learning/katas/java/Common Transforms/Aggregation/Mean/src/org/apache/beam/learning/katas/commontransforms/aggregation/mean/Task.java (31:42) - learning/katas/java/Common Transforms/Aggregation/Count/src/org/apache/beam/learning/katas/commontransforms/aggregation/count/Task.java (31:42) - learning/katas/java/Common Transforms/Aggregation/Max/src/org/apache/beam/learning/katas/commontransforms/aggregation/max/Task.java (31:42) - learning/katas/java/Common Transforms/Aggregation/Sum/src/org/apache/beam/learning/katas/commontransforms/aggregation/sum/Task.java (31:42) - learning/katas/java/Common Transforms/Aggregation/Min/src/org/apache/beam/learning/katas/commontransforms/aggregation/min/Task.java (31:42) - learning/katas/java/Common Transforms/Filter/ParDo/src/org/apache/beam/learning/katas/commontransforms/filter/pardo/Task.java (32:43) duplicated block id: 148 size: 6 cleaned lines of code in 3 files: - learning/katas/kotlin/Triggers/Early Triggers/Early Triggers/src/org/apache/beam/learning/katas/triggers/earlytriggers/Task.kt (34:45) - learning/katas/kotlin/Triggers/Window Accumulation Mode/Window Accumulation Mode/src/org/apache/beam/learning/katas/triggers/windowaccummode/Task.kt (34:45) - learning/katas/kotlin/Triggers/Event Time Triggers/Event Time Triggers/src/org/apache/beam/learning/katas/triggers/eventtimetriggers/Task.kt (33:44) duplicated block id: 149 size: 6 cleaned lines of code in 7 files: - learning/katas/kotlin/Common Transforms/Aggregation/Mean/src/org/apache/beam/learning/katas/commontransforms/aggregation/mean/Task.kt (29:40) - learning/katas/kotlin/Common Transforms/Aggregation/Count/src/org/apache/beam/learning/katas/commontransforms/aggregation/count/Task.kt (29:40) - learning/katas/kotlin/Common Transforms/Aggregation/Max/src/org/apache/beam/learning/katas/commontransforms/aggregation/max/Task.kt (29:40) - learning/katas/kotlin/Common Transforms/Aggregation/Sum/src/org/apache/beam/learning/katas/commontransforms/aggregation/sum/Task.kt (29:40) - learning/katas/kotlin/Common Transforms/Aggregation/Min/src/org/apache/beam/learning/katas/commontransforms/aggregation/min/Task.kt (29:40) - learning/katas/kotlin/Common Transforms/Filter/ParDo/src/org/apache/beam/learning/katas/commontransforms/filter/pardo/Task.kt (30:41) - learning/katas/kotlin/Common Transforms/Filter/Filter/src/org/apache/beam/learning/katas/commontransforms/filter/filter/Task.kt (30:41) duplicated block id: 150 size: 6 cleaned lines of code in 2 files: - learning/katas/kotlin/Core Transforms/Map/ParDo OneToMany/src/org/apache/beam/learning/katas/coretransforms/map/pardoonetomany/Task.kt (30:41) - learning/katas/kotlin/Core Transforms/Map/FlatMapElements/src/org/apache/beam/learning/katas/coretransforms/map/flatmapelements/Task.kt (31:42) duplicated block id: 151 size: 6 cleaned lines of code in 2 files: - buildSrc/src/main/groovy/org/apache/beam/gradle/GrpcVendoring_1_26_0.groovy (214:221) - buildSrc/src/main/groovy/org/apache/beam/gradle/GrpcVendoring_1_36_0.groovy (191:198) duplicated block id: 152 size: 6 cleaned lines of code in 3 files: - runners/jet/src/main/java/org/apache/beam/runners/jet/metrics/JetMetricResults.java (97:104) - runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/DefaultMetricResults.java (44:51) - runners/portability/java/src/main/java/org/apache/beam/runners/portability/PortableMetrics.java (57:64) duplicated block id: 153 size: 6 cleaned lines of code in 4 files: - runners/jet/src/main/java/org/apache/beam/runners/jet/processors/WindowGroupP.java (244:251) - runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/functions/GroupByWindowFunction.java (194:201) - runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/functions/GroupAlsoByWindowViaOutputBufferFn.java (160:167) - runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkGroupAlsoByWindowViaOutputBufferFn.java (153:160) duplicated block id: 154 size: 6 cleaned lines of code in 2 files: - runners/core-java/src/main/java/org/apache/beam/runners/core/GroupAlsoByWindowViaWindowSetNewDoFn.java (103:110) - runners/direct-java/src/main/java/org/apache/beam/runners/direct/SplittableProcessElementsEvaluatorFactory.java (162:169) duplicated block id: 155 size: 6 cleaned lines of code in 2 files: - runners/direct-java/src/main/java/org/apache/beam/runners/direct/PCollectionViewWindow.java (54:61) - runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/PCollectionViewWindow.java (54:61) duplicated block id: 156 size: 6 cleaned lines of code in 2 files: - runners/direct-java/src/main/java/org/apache/beam/runners/direct/StatefulParDoEvaluatorFactory.java (84:91) - runners/direct-java/src/main/java/org/apache/beam/runners/direct/SplittableProcessElementsEvaluatorFactory.java (97:104) duplicated block id: 157 size: 6 cleaned lines of code in 3 files: - runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/streaming/DatasetSourceStreaming.java (229:237) - runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/DatasetSourceBatch.java (138:145) - runners/spark/src/main/java/org/apache/beam/runners/spark/io/SourceRDD.java (214:221) duplicated block id: 158 size: 6 cleaned lines of code in 2 files: - runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/CoderHelpers.java (55:62) - runners/spark/src/main/java/org/apache/beam/runners/spark/coders/CoderHelpers.java (112:119) duplicated block id: 159 size: 6 cleaned lines of code in 2 files: - runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/aggregators/NamedAggregators.java (67:74) - runners/spark/src/main/java/org/apache/beam/runners/spark/aggregators/NamedAggregators.java (67:74) duplicated block id: 160 size: 6 cleaned lines of code in 2 files: - website/www/site/static/js/section-nav.js (75:82) - website/www/site/static/js/page-nav.js (83:90)