path	# lines of code
KeyspacesSink/src/main/java/com/amazonaws/services/kinesisanalytics/QueryOptionsSerializable.java	6
KeyspacesSink/src/main/java/com/amazonaws/services/kinesisanalytics/TurbineSpeedAggregator.java	97
KeyspacesSink/src/main/java/com/amazonaws/services/kinesisanalytics/TurbineAggregatedRecord.java	60
KeyspacesSink/src/main/java/com/amazonaws/services/kinesisanalytics/TurbineSensorMessageModel.java	9
HudiConnector/src/main/java/basic/application/StreamingJob.java	81
SlidingWindow/src/main/java/com/amazonaws/services/kinesisanalytics/SlidingWindowStreamingJobWithParallelism.java	54
SQSSink/src/main/java/com/amazonaws/services/kinesisanalytics/StandardSqsSink.java	20
SQSSink/src/main/java/com/amazonaws/services/kinesisanalytics/SQSSinkJob.java	47
GettingStarted_1_8/src/main/java/com/amazonaws/services/kinesisanalytics/BasicStreamingJob.java	50
CustomMetrics/RecordCount/src/main/java/com/amazonaws/services/kinesisanalytics/RecordSchemaHelper.java	25
CustomMetrics/RecordCount/src/main/java/com/amazonaws/services/kinesisanalytics/RecordCountApplication.java	75
CustomMetrics/WordCount/src/main/java/com/amazonaws/services/kinesisanalytics/WordCountApplication.java	61
EfoConsumer/src/main/java/software/amazon/kinesis/EfoApplication.java	46
S3ParquetSink/src/main/java/com/amazonaws/services/kinesisanalytics/S3StreamingParquetSinkJob.java	62
S3ParquetSink/src/main/java/com/amazonaws/services/kinesisanalytics/TickCount.java	21
GettingStarted_1_6/src/main/java/com/amazonaws/services/kinesisanalytics/BasicStreamingJob.java	50
python/SlidingWindow/sliding-windows.py	79
python/GettingStarted/getting-started.py	73
python/S3Sink/streaming-file-sink.py	91
python/TumblingWindow/tumbling-windows.py	76
CustomKeystore/src/main/java/com/amazonaws/services/kinesisanalytics/CustomFlinkKafkaConsumer.java	45
CustomKeystore/src/main/java/com/amazonaws/services/kinesisanalytics/KDAFlinkStreamingJob.java	41
KafkaConnectors/src/main/java/com/amazonaws/services/kinesisanalytics/KafkaGettingStartedJob.java	36
CloudWatchSink/src/main/java/com/amazonaws/services/kinesisanalytics/sink/CloudWatchLogSink.java	54
CloudWatchSink/src/main/java/com/amazonaws/services/kinesisanalytics/CustomSinkStreamingJob.java	84
LambdaSink/src/main/java/com/amazonaws/services/kinesisanalytics/AwsLambdaSink.java	139
LambdaSink/src/main/java/com/amazonaws/services/kinesisanalytics/LambdaSinkJob.java	45
LambdaSink/src/main/java/com/amazonaws/services/kinesisanalytics/TickCount.java	21
GettingStarted/src/main/java/com/amazonaws/services/kinesisanalytics/BasicStreamingJob.java	50
Beam/src/main/java/com/amazonaws/kinesisanalytics/beam/DefaultCredentialsProviderClientsProvider.java	29
Beam/src/main/java/com/amazonaws/kinesisanalytics/beam/BasicBeamStreamingJobOptions.java	12
Beam/src/main/java/com/amazonaws/kinesisanalytics/beam/BasicBeamStreamingJobOptionsParser.java	36
Beam/src/main/java/com/amazonaws/kinesisanalytics/beam/BasicBeamStreamingJob.java	75
GettingStarted_1_11/src/main/java/com/amazonaws/services/kinesisanalytics/BasicStreamingJob.java	50
GettingStartedTable/src/main/java/com/amazonaws/services/kinesisanalytics/StreamingJob.java	168
GettingStartedTable/src/main/python/stock.py	30
S3Sink/src/main/java/com/amazonaws/services/kinesisanalytics/S3StreamingSinkJob.java	53
TumblingWindow/src/main/java/com/amazonaws/services/kinesisanalytics/TumblingWindowStreamingJob.java	55
FirehoseSink/src/main/java/com/amazonaws/services/kinesisanalytics/FirehoseSinkStreamingJob.java	50