aws-samples / amazon-kinesis-data-analytics-java-examples
File Size

The distribution of size of files (measured in lines of code).

Intro
  • File size measurements show the distribution of size of files.
  • Files are classified in four categories based on their size (lines of code): 1-100 (very small files), 101-200 (small files), 201-500 (medium size files), 501-1000 (long files), 1001+(very long files).
  • It is a good practice to keep files small. Long files may become "bloaters", code that have increased to such gargantuan proportions that they are hard to work with.
Learn more...
File Size Overall
  • There are 39 files with 2,156 lines of code.
    • 0 very long files (0 lines of code)
    • 0 long files (0 lines of code)
    • 0 medium size files (0 lines of codeclsfd_ftr_w_mp_ins)
    • 2 small files (307 lines of code)
    • 37 very small files (1,849 lines of code)
0% | 0% | 0% | 14% | 85%
Legend:
1001+
501-1000
201-500
101-200
1-100


explore: zoomable circles | sunburst | 3D view
File Size per Extension
1001+
501-1000
201-500
101-200
1-100
java0% | 0% | 0% | 16% | 83%
py0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
GettingStartedTable0% | 0% | 0% | 84% | 15%
LambdaSink0% | 0% | 0% | 67% | 32%
python0% | 0% | 0% | 0% | 100%
KeyspacesSink0% | 0% | 0% | 0% | 100%
CustomMetrics0% | 0% | 0% | 0% | 100%
Beam0% | 0% | 0% | 0% | 100%
CloudWatchSink0% | 0% | 0% | 0% | 100%
CustomKeystore0% | 0% | 0% | 0% | 100%
S3ParquetSink0% | 0% | 0% | 0% | 100%
HudiConnector0% | 0% | 0% | 0% | 100%
SQSSink0% | 0% | 0% | 0% | 100%
TumblingWindow0% | 0% | 0% | 0% | 100%
SlidingWindow0% | 0% | 0% | 0% | 100%
S3Sink0% | 0% | 0% | 0% | 100%
GettingStarted_1_80% | 0% | 0% | 0% | 100%
GettingStarted_1_60% | 0% | 0% | 0% | 100%
GettingStarted0% | 0% | 0% | 0% | 100%
GettingStarted_1_110% | 0% | 0% | 0% | 100%
FirehoseSink0% | 0% | 0% | 0% | 100%
EfoConsumer0% | 0% | 0% | 0% | 100%
KafkaConnectors0% | 0% | 0% | 0% | 100%
Longest Files (Top 39)
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 -
Files With Most Units (Top 20)
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
Files With Long Lines (Top 20)

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