awslabs / kinesis-kafka-connector
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 36 units with 432 lines of code in units (55.8% of code).
    • 0 very long units (0 lines of code)
    • 1 long units (73 lines of code)
    • 4 medium size units (129 lines of code)
    • 8 small units (125 lines of code)
    • 23 very small units (105 lines of code)
0% | 16% | 29% | 28% | 24%
Legend:
101+
51-100
21-50
11-20
1-10
Unit Size per Extension
101+
51-100
21-50
11-20
1-10
java0% | 16% | 29% | 28% | 24%
Unit Size per Logical Component
primary logical decomposition
101+
51-100
21-50
11-20
1-10
kafka0% | 16% | 29% | 28% | 24%
Alternative Visuals
Longest Units
Top 20 longest units
Unit# linesMcCabe index# params
public static ByteBuffer parseValue()
in src/main/java/com/amazon/kinesis/kafka/DataUtility.java
73 22 2
private boolean validateOutStandingRecords()
in src/main/java/com/amazon/kinesis/kafka/AmazonKinesisSinkTask.java
49 11 0
public void start()
in src/main/java/com/amazon/kinesis/kafka/AmazonKinesisSinkTask.java
29 2 1
public void start()
in src/main/java/com/amazon/kinesis/kafka/FirehoseSinkTask.java
27 3 1
public void start()
in src/main/java/com/amazon/kinesis/kafka/AmazonKinesisSinkConnector.java
24 1 1
private void putRecordsInBatch()
in src/main/java/com/amazon/kinesis/kafka/FirehoseSinkTask.java
20 5 1
public void put()
in src/main/java/com/amazon/kinesis/kafka/AmazonKinesisSinkTask.java
19 5 1
public void flush()
in src/main/java/com/amazon/kinesis/kafka/AmazonKinesisSinkTask.java
16 4 1
private KinesisProducer getKinesisProducer()
in src/main/java/com/amazon/kinesis/kafka/AmazonKinesisSinkTask.java
16 2 0
static AWSCredentialsProvider createCredentials()
in src/main/java/com/amazon/kinesis/kafka/IAMUtility.java
14 4 5
private PutRecordBatchResult putRecordBatch()
in src/main/java/com/amazon/kinesis/kafka/FirehoseSinkTask.java
14 1 1
private void putRecords()
in src/main/java/com/amazon/kinesis/kafka/FirehoseSinkTask.java
14 2 1
public void start()
in src/main/java/com/amazon/kinesis/kafka/FirehoseSinkConnector.java
12 1 1
public void stop()
in src/main/java/com/amazon/kinesis/kafka/AmazonKinesisSinkTask.java
10 3 0
public void onFailure()
in src/main/java/com/amazon/kinesis/kafka/AmazonKinesisSinkTask.java
9 2 1
private ListenableFuture addUserRecord()
in src/main/java/com/amazon/kinesis/kafka/AmazonKinesisSinkTask.java
9 2 5
private void validateDeliveryStream()
in src/main/java/com/amazon/kinesis/kafka/FirehoseSinkTask.java
9 2 0
public void close()
in src/main/java/com/amazon/kinesis/kafka/AmazonKinesisSinkTask.java
8 3 1
private void checkForEarlierPutException()
in src/main/java/com/amazon/kinesis/kafka/AmazonKinesisSinkTask.java
7 2 0
public void open()
in src/main/java/com/amazon/kinesis/kafka/AmazonKinesisSinkTask.java
7 3 1