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

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

Intro
  • Unit size measurements show the distribution of size of units of code (methods, functions...).
  • Units are classified in four categories based on their size (lines of code): 1-20 (small units), 20-50 (medium size units), 51-100 (long units), 101+ (very long units).
  • You should aim at keeping units small (< 20 lines). Long units may become "bloaters", code that have increased to such gargantuan proportions that they are hard to work with.
Learn more...
Unit Size Overall
  • There are 152 units with 1,345 lines of code in units (62.4% of code).
    • 0 very long units (0 lines of code)
    • 0 long units (0 lines of code)
    • 15 medium size units (470 lines of code)
    • 13 small units (186 lines of code)
    • 124 very small units (689 lines of code)
0% | 0% | 34% | 13% | 51%
Legend:
101+
51-100
21-50
11-20
1-10
Unit Size per Extension
101+
51-100
21-50
11-20
1-10
java0% | 0% | 31% | 15% | 53%
py0% | 0% | 52% | 6% | 41%
Unit Size per Logical Component
primary logical decomposition
101+
51-100
21-50
11-20
1-10
python0% | 0% | 54% | 6% | 39%
GettingStartedTable0% | 0% | 76% | 0% | 23%
HudiConnector0% | 0% | 100% | 0% | 0%
LambdaSink0% | 0% | 31% | 10% | 58%
KeyspacesSink0% | 0% | 33% | 0% | 66%
CustomMetrics0% | 0% | 35% | 0% | 64%
Beam0% | 0% | 50% | 0% | 49%
CustomKeystore0% | 0% | 43% | 18% | 38%
CloudWatchSink0% | 0% | 31% | 37% | 31%
SlidingWindow0% | 0% | 0% | 48% | 51%
S3ParquetSink0% | 0% | 0% | 31% | 68%
TumblingWindow0% | 0% | 0% | 47% | 52%
FirehoseSink0% | 0% | 0% | 51% | 48%
SQSSink0% | 0% | 0% | 44% | 55%
S3Sink0% | 0% | 0% | 50% | 50%
EfoConsumer0% | 0% | 0% | 39% | 60%
KafkaConnectors0% | 0% | 0% | 50% | 50%
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%
Alternative Visuals
Longest Units
Top 20 longest units
Unit# linesMcCabe index# params
public void invoke()
in LambdaSink/src/main/java/com/amazonaws/services/kinesisanalytics/AwsLambdaSink.java
 45 8 2
public static void process()
in HudiConnector/src/main/java/basic/application/StreamingJob.java
 42 1 4
public static void process()
in GettingStartedTable/src/main/java/com/amazonaws/services/kinesisanalytics/StreamingJob.java
 38 1 4
public static void main()
in KeyspacesSink/src/main/java/com/amazonaws/services/kinesisanalytics/TurbineSpeedAggregator.java
 36 1 1
public static void main()
in CustomMetrics/RecordCount/src/main/java/com/amazonaws/services/kinesisanalytics/RecordCountApplication.java
 36 1 1
public static void process()
in GettingStartedTable/src/main/java/com/amazonaws/services/kinesisanalytics/StreamingJob.java
 31 1 4
def main()
in python/GettingStarted/getting-started.py
 30 2 0
public static void main()
in Beam/src/main/java/com/amazonaws/kinesisanalytics/beam/BasicBeamStreamingJob.java
 30 1 1
def main()
in python/S3Sink/streaming-file-sink.py
 28 2 0
def main()
in python/SlidingWindow/sliding-windows.py
 27 2 0
def main()
in python/TumblingWindow/tumbling-windows.py
 27 2 0
private void dropFile()
in CustomKeystore/src/main/java/com/amazonaws/services/kinesisanalytics/CustomFlinkKafkaConsumer.java
 26 4 1
private static void setupLogGroupAndStream()
in CloudWatchSink/src/main/java/com/amazonaws/services/kinesisanalytics/CustomSinkStreamingJob.java
 25 5 3
public static void main()
in GettingStartedTable/src/main/java/com/amazonaws/services/kinesisanalytics/StreamingJob.java
 25 3 1
public static void main()
in HudiConnector/src/main/java/basic/application/StreamingJob.java
 24 3 1
public static void main()
in SlidingWindow/src/main/java/com/amazonaws/services/kinesisanalytics/SlidingWindowStreamingJobWithParallelism.java
 17 1 1
public static void main()
in CloudWatchSink/src/main/java/com/amazonaws/services/kinesisanalytics/CustomSinkStreamingJob.java
 17 1 1
public static void main()
in S3ParquetSink/src/main/java/com/amazonaws/services/kinesisanalytics/S3StreamingParquetSinkJob.java
 16 1 1
public static void main()
in TumblingWindow/src/main/java/com/amazonaws/services/kinesisanalytics/TumblingWindowStreamingJob.java
 16 1 1
public static void main()
in FirehoseSink/src/main/java/com/amazonaws/services/kinesisanalytics/FirehoseSinkStreamingJob.java
 16 1 1