The distribution of size of files (measured in lines of code).
File | # lines | # units |
---|---|---|
StreamingJob.java in GettingStartedTable/src/main/java/com/amazonaws/services/kinesisanalytics |
168 | 7 |
AwsLambdaSink.java in LambdaSink/src/main/java/com/amazonaws/services/kinesisanalytics |
139 | 11 |
TurbineSpeedAggregator.java in KeyspacesSink/src/main/java/com/amazonaws/services/kinesisanalytics |
97 | 5 |
streaming-file-sink.py in python/S3Sink |
91 | 6 |
CustomSinkStreamingJob.java in CloudWatchSink/src/main/java/com/amazonaws/services/kinesisanalytics |
84 | 3 |
StreamingJob.java in HudiConnector/src/main/java/basic/application |
81 | 2 |
sliding-windows.py in python/SlidingWindow |
79 | 5 |
tumbling-windows.py in python/TumblingWindow |
76 | 5 |
RecordCountApplication.java in CustomMetrics/RecordCount/src/main/java/com/amazonaws/services/kinesisanalytics |
75 | 4 |
BasicBeamStreamingJob.java in Beam/src/main/java/com/amazonaws/kinesisanalytics/beam |
75 | 4 |
getting-started.py in python/GettingStarted |
73 | 5 |
S3StreamingParquetSinkJob.java in S3ParquetSink/src/main/java/com/amazonaws/services/kinesisanalytics |
62 | 3 |
WordCountApplication.java in CustomMetrics/WordCount/src/main/java/com/amazonaws/services/kinesisanalytics |
61 | 5 |
TurbineAggregatedRecord.java in KeyspacesSink/src/main/java/com/amazonaws/services/kinesisanalytics |
60 | 13 |
TumblingWindowStreamingJob.java in TumblingWindow/src/main/java/com/amazonaws/services/kinesisanalytics |
55 | 3 |
SlidingWindowStreamingJobWithParallelism.java in SlidingWindow/src/main/java/com/amazonaws/services/kinesisanalytics |
54 | 3 |
CloudWatchLogSink.java in CloudWatchSink/src/main/java/com/amazonaws/services/kinesisanalytics/sink |
54 | 4 |
S3StreamingSinkJob.java in S3Sink/src/main/java/com/amazonaws/services/kinesisanalytics |
53 | 3 |
BasicStreamingJob.java in GettingStarted_1_8/src/main/java/com/amazonaws/services/kinesisanalytics |
50 | 5 |
BasicStreamingJob.java in GettingStarted_1_6/src/main/java/com/amazonaws/services/kinesisanalytics |
50 | 5 |
BasicStreamingJob.java in GettingStarted/src/main/java/com/amazonaws/services/kinesisanalytics |
50 | 5 |
BasicStreamingJob.java in GettingStarted_1_11/src/main/java/com/amazonaws/services/kinesisanalytics |
50 | 5 |
FirehoseSinkStreamingJob.java in FirehoseSink/src/main/java/com/amazonaws/services/kinesisanalytics |
50 | 3 |
SQSSinkJob.java in SQSSink/src/main/java/com/amazonaws/services/kinesisanalytics |
47 | 3 |
EfoApplication.java in EfoConsumer/src/main/java/software/amazon/kinesis |
46 | 3 |
CustomFlinkKafkaConsumer.java in CustomKeystore/src/main/java/com/amazonaws/services/kinesisanalytics |
45 | 3 |
LambdaSinkJob.java in LambdaSink/src/main/java/com/amazonaws/services/kinesisanalytics |
45 | 3 |
KDAFlinkStreamingJob.java in CustomKeystore/src/main/java/com/amazonaws/services/kinesisanalytics |
41 | 3 |
KafkaGettingStartedJob.java in KafkaConnectors/src/main/java/com/amazonaws/services/kinesisanalytics |
36 | 3 |
BasicBeamStreamingJobOptionsParser.java in Beam/src/main/java/com/amazonaws/kinesisanalytics/beam |
36 | - |
stock.py in GettingStartedTable/src/main/python |
30 | 1 |
DefaultCredentialsProviderClientsProvider.java in Beam/src/main/java/com/amazonaws/kinesisanalytics/beam |
29 | 4 |
RecordSchemaHelper.java in CustomMetrics/RecordCount/src/main/java/com/amazonaws/services/kinesisanalytics |
25 | 3 |
TickCount.java in S3ParquetSink/src/main/java/com/amazonaws/services/kinesisanalytics |
21 | 5 |
TickCount.java in LambdaSink/src/main/java/com/amazonaws/services/kinesisanalytics |
21 | 5 |
StandardSqsSink.java in SQSSink/src/main/java/com/amazonaws/services/kinesisanalytics |
20 | 2 |
BasicBeamStreamingJobOptions.java in Beam/src/main/java/com/amazonaws/kinesisanalytics/beam |
12 | - |
TurbineSensorMessageModel.java in KeyspacesSink/src/main/java/com/amazonaws/services/kinesisanalytics |
9 | - |
QueryOptionsSerializable.java in KeyspacesSink/src/main/java/com/amazonaws/services/kinesisanalytics |
6 | - |
File | # lines | # units |
---|---|---|
TurbineAggregatedRecord.java in KeyspacesSink/src/main/java/com/amazonaws/services/kinesisanalytics |
60 | 13 |
AwsLambdaSink.java in LambdaSink/src/main/java/com/amazonaws/services/kinesisanalytics |
139 | 11 |
StreamingJob.java in GettingStartedTable/src/main/java/com/amazonaws/services/kinesisanalytics |
168 | 7 |
streaming-file-sink.py in python/S3Sink |
91 | 6 |
TurbineSpeedAggregator.java in KeyspacesSink/src/main/java/com/amazonaws/services/kinesisanalytics |
97 | 5 |
BasicStreamingJob.java in GettingStarted_1_8/src/main/java/com/amazonaws/services/kinesisanalytics |
50 | 5 |
WordCountApplication.java in CustomMetrics/WordCount/src/main/java/com/amazonaws/services/kinesisanalytics |
61 | 5 |
TickCount.java in S3ParquetSink/src/main/java/com/amazonaws/services/kinesisanalytics |
21 | 5 |
BasicStreamingJob.java in GettingStarted_1_6/src/main/java/com/amazonaws/services/kinesisanalytics |
50 | 5 |
sliding-windows.py in python/SlidingWindow |
79 | 5 |
getting-started.py in python/GettingStarted |
73 | 5 |
tumbling-windows.py in python/TumblingWindow |
76 | 5 |
TickCount.java in LambdaSink/src/main/java/com/amazonaws/services/kinesisanalytics |
21 | 5 |
BasicStreamingJob.java in GettingStarted/src/main/java/com/amazonaws/services/kinesisanalytics |
50 | 5 |
BasicStreamingJob.java in GettingStarted_1_11/src/main/java/com/amazonaws/services/kinesisanalytics |
50 | 5 |
RecordCountApplication.java in CustomMetrics/RecordCount/src/main/java/com/amazonaws/services/kinesisanalytics |
75 | 4 |
CloudWatchLogSink.java in CloudWatchSink/src/main/java/com/amazonaws/services/kinesisanalytics/sink |
54 | 4 |
DefaultCredentialsProviderClientsProvider.java in Beam/src/main/java/com/amazonaws/kinesisanalytics/beam |
29 | 4 |
BasicBeamStreamingJob.java in Beam/src/main/java/com/amazonaws/kinesisanalytics/beam |
75 | 4 |
SlidingWindowStreamingJobWithParallelism.java in SlidingWindow/src/main/java/com/amazonaws/services/kinesisanalytics |
54 | 3 |
There are 21 files with lines longer than 120 characters. In total, there are 42 long lines.
File | # lines | # units | # long lines |
---|---|---|---|
StreamingJob.java in GettingStartedTable/src/main/java/com/amazonaws/services/kinesisanalytics |
168 | 7 | 7 |
StreamingJob.java in HudiConnector/src/main/java/basic/application |
81 | 2 | 4 |
AwsLambdaSink.java in LambdaSink/src/main/java/com/amazonaws/services/kinesisanalytics |
139 | 11 | 4 |
TurbineAggregatedRecord.java in KeyspacesSink/src/main/java/com/amazonaws/services/kinesisanalytics |
60 | 13 | 3 |
RecordCountApplication.java in CustomMetrics/RecordCount/src/main/java/com/amazonaws/services/kinesisanalytics |
75 | 4 | 3 |
CloudWatchLogSink.java in CloudWatchSink/src/main/java/com/amazonaws/services/kinesisanalytics/sink |
54 | 4 | 3 |
EfoApplication.java in EfoConsumer/src/main/java/software/amazon/kinesis |
46 | 3 | 2 |
BasicBeamStreamingJobOptionsParser.java in Beam/src/main/java/com/amazonaws/kinesisanalytics/beam |
36 | - | 2 |
BasicBeamStreamingJob.java in Beam/src/main/java/com/amazonaws/kinesisanalytics/beam |
75 | 4 | 2 |
TurbineSpeedAggregator.java in KeyspacesSink/src/main/java/com/amazonaws/services/kinesisanalytics |
97 | 5 | 1 |
SQSSinkJob.java in SQSSink/src/main/java/com/amazonaws/services/kinesisanalytics |
47 | 3 | 1 |
BasicStreamingJob.java in GettingStarted_1_8/src/main/java/com/amazonaws/services/kinesisanalytics |
50 | 5 | 1 |
WordCountApplication.java in CustomMetrics/WordCount/src/main/java/com/amazonaws/services/kinesisanalytics |
61 | 5 | 1 |
BasicStreamingJob.java in GettingStarted_1_6/src/main/java/com/amazonaws/services/kinesisanalytics |
50 | 5 | 1 |
KDAFlinkStreamingJob.java in CustomKeystore/src/main/java/com/amazonaws/services/kinesisanalytics |
41 | 3 | 1 |
KafkaGettingStartedJob.java in KafkaConnectors/src/main/java/com/amazonaws/services/kinesisanalytics |
36 | 3 | 1 |
CustomSinkStreamingJob.java in CloudWatchSink/src/main/java/com/amazonaws/services/kinesisanalytics |
84 | 3 | 1 |
BasicStreamingJob.java in GettingStarted/src/main/java/com/amazonaws/services/kinesisanalytics |
50 | 5 | 1 |
BasicStreamingJob.java in GettingStarted_1_11/src/main/java/com/amazonaws/services/kinesisanalytics |
50 | 5 | 1 |
stock.py in GettingStartedTable/src/main/python |
30 | 1 | 1 |