duplicated block id: 1 size: 33 cleaned lines of code in 2 files: - python/SlidingWindow/sliding-windows.py (21:80) - python/TumblingWindow/tumbling-windows.py (21:80) duplicated block id: 2 size: 33 cleaned lines of code in 2 files: - python/GettingStarted/getting-started.py (18:77) - python/SlidingWindow/sliding-windows.py (21:80) duplicated block id: 3 size: 33 cleaned lines of code in 2 files: - GettingStarted_1_11/src/main/java/com/amazonaws/services/kinesisanalytics/BasicStreamingJob.java (19:73) - GettingStarted_1_6/src/main/java/com/amazonaws/services/kinesisanalytics/BasicStreamingJob.java (19:73) duplicated block id: 4 size: 33 cleaned lines of code in 2 files: - GettingStarted_1_6/src/main/java/com/amazonaws/services/kinesisanalytics/BasicStreamingJob.java (19:73) - GettingStarted_1_8/src/main/java/com/amazonaws/services/kinesisanalytics/BasicStreamingJob.java (19:73) duplicated block id: 5 size: 33 cleaned lines of code in 2 files: - python/GettingStarted/getting-started.py (18:77) - python/TumblingWindow/tumbling-windows.py (21:80) duplicated block id: 6 size: 33 cleaned lines of code in 2 files: - GettingStarted/src/main/java/com/amazonaws/services/kinesisanalytics/BasicStreamingJob.java (19:73) - GettingStarted_1_6/src/main/java/com/amazonaws/services/kinesisanalytics/BasicStreamingJob.java (19:73) duplicated block id: 7 size: 33 cleaned lines of code in 2 files: - GettingStarted_1_11/src/main/java/com/amazonaws/services/kinesisanalytics/BasicStreamingJob.java (19:73) - GettingStarted_1_8/src/main/java/com/amazonaws/services/kinesisanalytics/BasicStreamingJob.java (19:73) duplicated block id: 8 size: 33 cleaned lines of code in 2 files: - GettingStarted/src/main/java/com/amazonaws/services/kinesisanalytics/BasicStreamingJob.java (19:73) - GettingStarted_1_8/src/main/java/com/amazonaws/services/kinesisanalytics/BasicStreamingJob.java (19:73) duplicated block id: 9 size: 33 cleaned lines of code in 2 files: - GettingStarted/src/main/java/com/amazonaws/services/kinesisanalytics/BasicStreamingJob.java (19:73) - GettingStarted_1_11/src/main/java/com/amazonaws/services/kinesisanalytics/BasicStreamingJob.java (19:73) duplicated block id: 10 size: 26 cleaned lines of code in 2 files: - SlidingWindow/src/main/java/com/amazonaws/services/kinesisanalytics/SlidingWindowStreamingJobWithParallelism.java (37:70) - TumblingWindow/src/main/java/com/amazonaws/services/kinesisanalytics/TumblingWindowStreamingJob.java (26:62) duplicated block id: 11 size: 24 cleaned lines of code in 2 files: - python/GettingStarted/getting-started.py (94:131) - python/SlidingWindow/sliding-windows.py (101:138) duplicated block id: 12 size: 24 cleaned lines of code in 2 files: - python/GettingStarted/getting-started.py (94:131) - python/TumblingWindow/tumbling-windows.py (98:135) duplicated block id: 13 size: 24 cleaned lines of code in 2 files: - python/SlidingWindow/sliding-windows.py (101:138) - python/TumblingWindow/tumbling-windows.py (98:135) duplicated block id: 14 size: 14 cleaned lines of code in 2 files: - CustomKeystore/src/main/java/com/amazonaws/services/kinesisanalytics/KDAFlinkStreamingJob.java (33:55) - KafkaConnectors/src/main/java/com/amazonaws/services/kinesisanalytics/KafkaGettingStartedJob.java (25:47) duplicated block id: 15 size: 14 cleaned lines of code in 2 files: - python/S3Sink/streaming-file-sink.py (21:40) - python/SlidingWindow/sliding-windows.py (21:39) duplicated block id: 16 size: 14 cleaned lines of code in 2 files: - GettingStartedTable/src/main/java/com/amazonaws/services/kinesisanalytics/StreamingJob.java (106:119) - GettingStartedTable/src/main/java/com/amazonaws/services/kinesisanalytics/StreamingJob.java (154:167) duplicated block id: 17 size: 14 cleaned lines of code in 2 files: - LambdaSink/src/main/java/com/amazonaws/services/kinesisanalytics/TickCount.java (3:25) - S3ParquetSink/src/main/java/com/amazonaws/services/kinesisanalytics/TickCount.java (3:25) duplicated block id: 18 size: 14 cleaned lines of code in 2 files: - python/GettingStarted/getting-started.py (18:36) - python/S3Sink/streaming-file-sink.py (21:40) duplicated block id: 19 size: 14 cleaned lines of code in 2 files: - python/S3Sink/streaming-file-sink.py (21:40) - python/TumblingWindow/tumbling-windows.py (21:39) duplicated block id: 20 size: 13 cleaned lines of code in 2 files: - python/S3Sink/streaming-file-sink.py (53:69) - python/TumblingWindow/tumbling-windows.py (41:57) duplicated block id: 21 size: 13 cleaned lines of code in 2 files: - python/S3Sink/streaming-file-sink.py (53:69) - python/SlidingWindow/sliding-windows.py (41:57) duplicated block id: 22 size: 13 cleaned lines of code in 2 files: - S3ParquetSink/src/main/java/com/amazonaws/services/kinesisanalytics/S3StreamingParquetSinkJob.java (51:70) - S3Sink/src/main/java/com/amazonaws/services/kinesisanalytics/S3StreamingSinkJob.java (42:61) duplicated block id: 23 size: 13 cleaned lines of code in 2 files: - python/GettingStarted/getting-started.py (38:54) - python/S3Sink/streaming-file-sink.py (53:69) duplicated block id: 24 size: 13 cleaned lines of code in 2 files: - GettingStartedTable/src/main/java/com/amazonaws/services/kinesisanalytics/StreamingJob.java (42:61) - HudiConnector/src/main/java/basic/application/StreamingJob.java (53:71) duplicated block id: 25 size: 12 cleaned lines of code in 2 files: - LambdaSink/src/main/java/com/amazonaws/services/kinesisanalytics/LambdaSinkJob.java (37:53) - S3ParquetSink/src/main/java/com/amazonaws/services/kinesisanalytics/S3StreamingParquetSinkJob.java (55:71) duplicated block id: 26 size: 11 cleaned lines of code in 2 files: - S3Sink/src/main/java/com/amazonaws/services/kinesisanalytics/S3StreamingSinkJob.java (46:61) - SQSSink/src/main/java/com/amazonaws/services/kinesisanalytics/SQSSinkJob.java (39:54) duplicated block id: 27 size: 11 cleaned lines of code in 2 files: - LambdaSink/src/main/java/com/amazonaws/services/kinesisanalytics/LambdaSinkJob.java (37:52) - SQSSink/src/main/java/com/amazonaws/services/kinesisanalytics/SQSSinkJob.java (39:54) duplicated block id: 28 size: 11 cleaned lines of code in 2 files: - S3ParquetSink/src/main/java/com/amazonaws/services/kinesisanalytics/S3StreamingParquetSinkJob.java (27:39) - S3Sink/src/main/java/com/amazonaws/services/kinesisanalytics/S3StreamingSinkJob.java (23:35) duplicated block id: 29 size: 11 cleaned lines of code in 2 files: - LambdaSink/src/main/java/com/amazonaws/services/kinesisanalytics/LambdaSinkJob.java (37:52) - S3Sink/src/main/java/com/amazonaws/services/kinesisanalytics/S3StreamingSinkJob.java (46:61) duplicated block id: 30 size: 11 cleaned lines of code in 2 files: - S3ParquetSink/src/main/java/com/amazonaws/services/kinesisanalytics/S3StreamingParquetSinkJob.java (55:70) - SQSSink/src/main/java/com/amazonaws/services/kinesisanalytics/SQSSinkJob.java (39:54) duplicated block id: 31 size: 8 cleaned lines of code in 2 files: - FirehoseSink/src/main/java/com/amazonaws/services/kinesisanalytics/FirehoseSinkStreamingJob.java (37:45) - TumblingWindow/src/main/java/com/amazonaws/services/kinesisanalytics/TumblingWindowStreamingJob.java (30:38) duplicated block id: 32 size: 8 cleaned lines of code in 2 files: - CustomMetrics/WordCount/src/main/java/com/amazonaws/services/kinesisanalytics/WordCountApplication.java (34:42) - GettingStarted_1_11/src/main/java/com/amazonaws/services/kinesisanalytics/BasicStreamingJob.java (38:46) duplicated block id: 33 size: 8 cleaned lines of code in 2 files: - CloudWatchSink/src/main/java/com/amazonaws/services/kinesisanalytics/CustomSinkStreamingJob.java (70:78) - SlidingWindow/src/main/java/com/amazonaws/services/kinesisanalytics/SlidingWindowStreamingJobWithParallelism.java (41:49) duplicated block id: 34 size: 8 cleaned lines of code in 2 files: - FirehoseSink/src/main/java/com/amazonaws/services/kinesisanalytics/FirehoseSinkStreamingJob.java (37:45) - SlidingWindow/src/main/java/com/amazonaws/services/kinesisanalytics/SlidingWindowStreamingJobWithParallelism.java (41:49) duplicated block id: 35 size: 8 cleaned lines of code in 2 files: - S3Sink/src/main/java/com/amazonaws/services/kinesisanalytics/S3StreamingSinkJob.java (27:35) - SQSSink/src/main/java/com/amazonaws/services/kinesisanalytics/SQSSinkJob.java (24:32) duplicated block id: 36 size: 8 cleaned lines of code in 2 files: - CustomMetrics/WordCount/src/main/java/com/amazonaws/services/kinesisanalytics/WordCountApplication.java (34:42) - GettingStarted_1_8/src/main/java/com/amazonaws/services/kinesisanalytics/BasicStreamingJob.java (38:46) duplicated block id: 37 size: 8 cleaned lines of code in 2 files: - LambdaSink/src/main/java/com/amazonaws/services/kinesisanalytics/LambdaSinkJob.java (22:30) - S3ParquetSink/src/main/java/com/amazonaws/services/kinesisanalytics/S3StreamingParquetSinkJob.java (31:39) duplicated block id: 38 size: 8 cleaned lines of code in 2 files: - CustomMetrics/WordCount/src/main/java/com/amazonaws/services/kinesisanalytics/WordCountApplication.java (34:42) - GettingStarted/src/main/java/com/amazonaws/services/kinesisanalytics/BasicStreamingJob.java (38:46) duplicated block id: 39 size: 8 cleaned lines of code in 2 files: - CloudWatchSink/src/main/java/com/amazonaws/services/kinesisanalytics/CustomSinkStreamingJob.java (70:78) - FirehoseSink/src/main/java/com/amazonaws/services/kinesisanalytics/FirehoseSinkStreamingJob.java (37:45) duplicated block id: 40 size: 8 cleaned lines of code in 2 files: - CustomMetrics/WordCount/src/main/java/com/amazonaws/services/kinesisanalytics/WordCountApplication.java (34:42) - GettingStarted_1_6/src/main/java/com/amazonaws/services/kinesisanalytics/BasicStreamingJob.java (38:46) duplicated block id: 41 size: 8 cleaned lines of code in 2 files: - S3ParquetSink/src/main/java/com/amazonaws/services/kinesisanalytics/S3StreamingParquetSinkJob.java (31:39) - SQSSink/src/main/java/com/amazonaws/services/kinesisanalytics/SQSSinkJob.java (24:32) duplicated block id: 42 size: 8 cleaned lines of code in 2 files: - LambdaSink/src/main/java/com/amazonaws/services/kinesisanalytics/LambdaSinkJob.java (22:30) - SQSSink/src/main/java/com/amazonaws/services/kinesisanalytics/SQSSinkJob.java (24:32) duplicated block id: 43 size: 8 cleaned lines of code in 2 files: - CloudWatchSink/src/main/java/com/amazonaws/services/kinesisanalytics/CustomSinkStreamingJob.java (70:78) - TumblingWindow/src/main/java/com/amazonaws/services/kinesisanalytics/TumblingWindowStreamingJob.java (30:38) duplicated block id: 44 size: 8 cleaned lines of code in 2 files: - LambdaSink/src/main/java/com/amazonaws/services/kinesisanalytics/LambdaSinkJob.java (22:30) - S3Sink/src/main/java/com/amazonaws/services/kinesisanalytics/S3StreamingSinkJob.java (27:35) duplicated block id: 45 size: 7 cleaned lines of code in 2 files: - CustomMetrics/WordCount/src/main/java/com/amazonaws/services/kinesisanalytics/WordCountApplication.java (23:31) - GettingStarted_1_11/src/main/java/com/amazonaws/services/kinesisanalytics/BasicStreamingJob.java (21:29) duplicated block id: 46 size: 7 cleaned lines of code in 2 files: - LambdaSink/src/main/java/com/amazonaws/services/kinesisanalytics/LambdaSinkJob.java (41:49) - TumblingWindow/src/main/java/com/amazonaws/services/kinesisanalytics/TumblingWindowStreamingJob.java (57:65) duplicated block id: 47 size: 7 cleaned lines of code in 2 files: - S3Sink/src/main/java/com/amazonaws/services/kinesisanalytics/S3StreamingSinkJob.java (50:58) - TumblingWindow/src/main/java/com/amazonaws/services/kinesisanalytics/TumblingWindowStreamingJob.java (57:65) duplicated block id: 48 size: 7 cleaned lines of code in 2 files: - S3ParquetSink/src/main/java/com/amazonaws/services/kinesisanalytics/S3StreamingParquetSinkJob.java (59:67) - TumblingWindow/src/main/java/com/amazonaws/services/kinesisanalytics/TumblingWindowStreamingJob.java (57:65) duplicated block id: 49 size: 7 cleaned lines of code in 2 files: - CustomMetrics/WordCount/src/main/java/com/amazonaws/services/kinesisanalytics/WordCountApplication.java (23:31) - GettingStarted/src/main/java/com/amazonaws/services/kinesisanalytics/BasicStreamingJob.java (21:29) duplicated block id: 50 size: 7 cleaned lines of code in 2 files: - CustomMetrics/WordCount/src/main/java/com/amazonaws/services/kinesisanalytics/WordCountApplication.java (23:31) - GettingStarted_1_8/src/main/java/com/amazonaws/services/kinesisanalytics/BasicStreamingJob.java (21:29) duplicated block id: 51 size: 7 cleaned lines of code in 2 files: - CustomMetrics/WordCount/src/main/java/com/amazonaws/services/kinesisanalytics/WordCountApplication.java (23:31) - GettingStarted_1_6/src/main/java/com/amazonaws/services/kinesisanalytics/BasicStreamingJob.java (21:29) duplicated block id: 52 size: 7 cleaned lines of code in 2 files: - SQSSink/src/main/java/com/amazonaws/services/kinesisanalytics/SQSSinkJob.java (43:51) - TumblingWindow/src/main/java/com/amazonaws/services/kinesisanalytics/TumblingWindowStreamingJob.java (57:65) duplicated block id: 53 size: 6 cleaned lines of code in 2 files: - CustomMetrics/WordCount/src/main/java/com/amazonaws/services/kinesisanalytics/WordCountApplication.java (40:50) - GettingStarted_1_11/src/main/java/com/amazonaws/services/kinesisanalytics/BasicStreamingJob.java (54:66) duplicated block id: 54 size: 6 cleaned lines of code in 2 files: - CustomMetrics/WordCount/src/main/java/com/amazonaws/services/kinesisanalytics/WordCountApplication.java (40:50) - GettingStarted_1_6/src/main/java/com/amazonaws/services/kinesisanalytics/BasicStreamingJob.java (54:66) duplicated block id: 55 size: 6 cleaned lines of code in 2 files: - CustomMetrics/WordCount/src/main/java/com/amazonaws/services/kinesisanalytics/WordCountApplication.java (40:50) - GettingStarted_1_8/src/main/java/com/amazonaws/services/kinesisanalytics/BasicStreamingJob.java (54:66) duplicated block id: 56 size: 6 cleaned lines of code in 2 files: - CustomMetrics/WordCount/src/main/java/com/amazonaws/services/kinesisanalytics/WordCountApplication.java (40:50) - GettingStarted/src/main/java/com/amazonaws/services/kinesisanalytics/BasicStreamingJob.java (54:66)