path # lines of code number of updates days since first update days since last update first updated last updated KeyspacesSink/src/main/java/com/amazonaws/services/kinesisanalytics/QueryOptionsSerializable.java 6 2 14 11 2022-01-18 2022-01-21 KeyspacesSink/src/main/java/com/amazonaws/services/kinesisanalytics/TurbineSpeedAggregator.java 97 3 14 11 2022-01-18 2022-01-21 KeyspacesSink/src/main/java/com/amazonaws/services/kinesisanalytics/TurbineAggregatedRecord.java 60 2 14 11 2022-01-18 2022-01-21 KeyspacesSink/src/main/java/com/amazonaws/services/kinesisanalytics/TurbineSensorMessageModel.java 9 2 12 11 2022-01-20 2022-01-21 HudiConnector/src/main/java/basic/application/StreamingJob.java 81 3 27 20 2022-01-05 2022-01-12 SlidingWindow/src/main/java/com/amazonaws/services/kinesisanalytics/SlidingWindowStreamingJobWithParallelism.java 54 2 1008 85 2019-04-30 2021-11-08 SQSSink/src/main/java/com/amazonaws/services/kinesisanalytics/StandardSqsSink.java 20 2 71 70 2021-11-22 2021-11-23 SQSSink/src/main/java/com/amazonaws/services/kinesisanalytics/SQSSinkJob.java 47 2 71 70 2021-11-22 2021-11-23 GettingStarted_1_8/src/main/java/com/amazonaws/services/kinesisanalytics/BasicStreamingJob.java 50 1 406 406 2020-12-22 2020-12-22 CustomMetrics/RecordCount/src/main/java/com/amazonaws/services/kinesisanalytics/RecordSchemaHelper.java 25 2 630 368 2020-05-12 2021-01-29 CustomMetrics/RecordCount/src/main/java/com/amazonaws/services/kinesisanalytics/RecordCountApplication.java 75 1 630 630 2020-05-12 2020-05-12 CustomMetrics/WordCount/src/main/java/com/amazonaws/services/kinesisanalytics/WordCountApplication.java 61 1 630 630 2020-05-12 2020-05-12 EfoConsumer/src/main/java/software/amazon/kinesis/EfoApplication.java 46 2 482 111 2020-10-07 2021-10-13 S3ParquetSink/src/main/java/com/amazonaws/services/kinesisanalytics/S3StreamingParquetSinkJob.java 62 2 71 70 2021-11-22 2021-11-23 S3ParquetSink/src/main/java/com/amazonaws/services/kinesisanalytics/TickCount.java 21 2 71 70 2021-11-22 2021-11-23 GettingStarted_1_6/src/main/java/com/amazonaws/services/kinesisanalytics/BasicStreamingJob.java 50 1 777 777 2019-12-17 2019-12-17 python/SlidingWindow/sliding-windows.py 79 4 313 69 2021-03-25 2021-11-24 python/GettingStarted/getting-started.py 73 3 313 69 2021-03-25 2021-11-24 python/S3Sink/streaming-file-sink.py 91 4 313 69 2021-03-25 2021-11-24 python/TumblingWindow/tumbling-windows.py 76 4 313 69 2021-03-25 2021-11-24 CustomKeystore/src/main/java/com/amazonaws/services/kinesisanalytics/CustomFlinkKafkaConsumer.java 45 1 595 595 2020-06-16 2020-06-16 CustomKeystore/src/main/java/com/amazonaws/services/kinesisanalytics/KDAFlinkStreamingJob.java 41 1 595 595 2020-06-16 2020-06-16 KafkaConnectors/src/main/java/com/amazonaws/services/kinesisanalytics/KafkaGettingStartedJob.java 36 3 799 705 2019-11-25 2020-02-27 CloudWatchSink/src/main/java/com/amazonaws/services/kinesisanalytics/sink/CloudWatchLogSink.java 54 1 1008 1008 2019-04-30 2019-04-30 CloudWatchSink/src/main/java/com/amazonaws/services/kinesisanalytics/CustomSinkStreamingJob.java 84 1 1008 1008 2019-04-30 2019-04-30 LambdaSink/src/main/java/com/amazonaws/services/kinesisanalytics/AwsLambdaSink.java 139 2 71 70 2021-11-22 2021-11-23 LambdaSink/src/main/java/com/amazonaws/services/kinesisanalytics/LambdaSinkJob.java 45 1 70 70 2021-11-23 2021-11-23 LambdaSink/src/main/java/com/amazonaws/services/kinesisanalytics/TickCount.java 21 2 71 70 2021-11-22 2021-11-23 GettingStarted/src/main/java/com/amazonaws/services/kinesisanalytics/BasicStreamingJob.java 50 1 1008 1008 2019-04-30 2019-04-30 Beam/src/main/java/com/amazonaws/kinesisanalytics/beam/DefaultCredentialsProviderClientsProvider.java 29 2 509 505 2020-09-10 2020-09-14 Beam/src/main/java/com/amazonaws/kinesisanalytics/beam/BasicBeamStreamingJobOptions.java 12 2 509 505 2020-09-10 2020-09-14 Beam/src/main/java/com/amazonaws/kinesisanalytics/beam/BasicBeamStreamingJobOptionsParser.java 36 1 505 505 2020-09-14 2020-09-14 Beam/src/main/java/com/amazonaws/kinesisanalytics/beam/BasicBeamStreamingJob.java 75 2 509 505 2020-09-10 2020-09-14 GettingStarted_1_11/src/main/java/com/amazonaws/services/kinesisanalytics/BasicStreamingJob.java 50 1 85 85 2021-11-08 2021-11-08 GettingStartedTable/src/main/java/com/amazonaws/services/kinesisanalytics/StreamingJob.java 168 1 439 439 2020-11-19 2020-11-19 GettingStartedTable/src/main/python/stock.py 30 1 439 439 2020-11-19 2020-11-19 S3Sink/src/main/java/com/amazonaws/services/kinesisanalytics/S3StreamingSinkJob.java 53 3 777 85 2019-12-17 2021-11-08 TumblingWindow/src/main/java/com/amazonaws/services/kinesisanalytics/TumblingWindowStreamingJob.java 55 2 1008 85 2019-04-30 2021-11-08 FirehoseSink/src/main/java/com/amazonaws/services/kinesisanalytics/FirehoseSinkStreamingJob.java 50 1 1008 1008 2019-04-30 2019-04-30