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.
File Size Overall
- There are 64 files with 6,374 lines of code.
- 0 very long files (0 lines of code)
- 1 long files (796 lines of code)
- 7 medium size files (1,940 lines of codeclsfd_ftr_w_mp_ins)
- 15 small files (2,138 lines of code)
- 41 very small files (1,500 lines of code)
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
File Size per Logical Decomposition
primary
Longest Files (Top 50)
| File | # lines | # units |
|---|---|---|
 KinesisDataFetcher.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals |
796 | 44 |
KinesisConfigUtil.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
347 | 13 |
KinesisProxy.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy |
341 | 12 |
FanOutShardSubscriber.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout |
318 | 27 |
FlinkKinesisConsumer.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink |
248 | 17 |
FlinkKinesisProducer.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink |
247 | 16 |
FanOutRecordPublisherConfiguration.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout |
221 | 27 |
AwsV2Util.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
218 | 15 |
StreamConsumerRegistrar.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout |
176 | 15 |
AWSUtil.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
172 | 9 |
RecordEmitter.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
169 | 13 |
RowDataFieldsKinesisPartitioner.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table |
168 | 9 |
KinesisOptions.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table |
165 | 8 |
FanOutRecordPublisher.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout |
160 | 5 |
StreamShardMetadata.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/model |
156 | 23 |
KinesisProxyV2.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy |
145 | 10 |
ConsumerConfigConstants.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/config |
134 | 2 |
ShardConsumer.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals |
134 | 7 |
JobManagerWatermarkTracker.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
130 | 8 |
PollingRecordPublisher.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/polling |
114 | 6 |
KinesisDynamicSink.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table |
110 | 8 |
KinesisDynamicTableFactory.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table |
104 | 6 |
StreamConsumerRegistrarUtil.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
101 | 9 |
KinesisDynamicSource.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table |
90 | 7 |
DynamoDBStreamsProxy.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy |
83 | 5 |
DynamoDBStreamsDataFetcher.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals |
69 | 3 |
KinesisStreamShard.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/model |
67 | 8 |
StartingPosition.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/model |
55 | 9 |
AdaptivePollingRecordPublisher.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/polling |
55 | 2 |
AWSConfigConstants.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/config |
54 | 9 |
KinesisStreamShardState.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/model |
54 | 8 |
SequenceNumber.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/model |
53 | 8 |
StreamShardHandle.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/model |
51 | 8 |
RecordBatch.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher |
50 | 8 |
PollingRecordPublisherFactory.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/polling |
50 | 2 |
PollingRecordPublisherMetricsReporter.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/metrics |
49 | 11 |
ShardConsumerMetricsReporter.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/metrics |
49 | 10 |
WatermarkTracker.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
48 | 8 |
BeanDeserializerModifierForIgnorables.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
46 | 3 |
GetShardListResult.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy |
46 | 6 |
FanOutRecordPublisherFactory.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout |
43 | 3 |
FlinkDynamoDBStreamsConsumer.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink |
41 | 3 |
FixedKinesisPartitioner.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink |
40 | 4 |
RowDataKinesisDeserializationSchema.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table |
39 | 4 |
KinesisDeserializationSchemaWrapper.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/serialization |
37 | 4 |
KinesisProxyV2Factory.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy |
30 | 2 |
PollingRecordPublisherConfiguration.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/polling |
30 | 4 |
SentinelSequenceNumber.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/model |
26 | 2 |
DynamoDBStreamsShardHandle.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/model |
23 | 3 |
TimeoutLatch.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
21 | 2 |
Files With Most Units (Top 20)
| File | # lines | # units |
|---|---|---|
KinesisDataFetcher.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals |
796 | 44 |
FanOutShardSubscriber.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout |
318 | 27 |
FanOutRecordPublisherConfiguration.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout |
221 | 27 |
StreamShardMetadata.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/model |
156 | 23 |
FlinkKinesisConsumer.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink |
248 | 17 |
FlinkKinesisProducer.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink |
247 | 16 |
AwsV2Util.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
218 | 15 |
StreamConsumerRegistrar.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout |
176 | 15 |
RecordEmitter.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
169 | 13 |
KinesisConfigUtil.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
347 | 13 |
KinesisProxy.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy |
341 | 12 |
PollingRecordPublisherMetricsReporter.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/metrics |
49 | 11 |
KinesisProxyV2.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy |
145 | 10 |
ShardConsumerMetricsReporter.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/metrics |
49 | 10 |
RowDataFieldsKinesisPartitioner.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table |
168 | 9 |
AWSConfigConstants.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/config |
54 | 9 |
StartingPosition.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/model |
55 | 9 |
StreamConsumerRegistrarUtil.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
101 | 9 |
AWSUtil.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
172 | 9 |
KinesisOptions.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table |
165 | 8 |
Files With Long Lines (Top 20)
There are 31 files with lines longer than 120 characters. In total, there are 186 long lines.
| File | # lines | # units | # long lines |
|---|---|---|---|
KinesisConfigUtil.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
347 | 13 | 58 |
AwsV2Util.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
218 | 15 | 11 |
FlinkKinesisConsumer.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink |
248 | 17 | 11 |
StreamConsumerRegistrar.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout |
176 | 15 | 10 |
FanOutRecordPublisher.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout |
160 | 5 | 10 |
ConsumerConfigConstants.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/config |
134 | 2 | 8 |
KinesisProxyV2.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy |
145 | 10 | 7 |
KinesisProxy.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy |
341 | 12 | 7 |
FanOutRecordPublisherConfiguration.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout |
221 | 27 | 7 |
KinesisDataFetcher.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals |
796 | 44 | 7 |
AWSUtil.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/util |
172 | 9 | 5 |
KinesisProxyV2Interface.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy |
21 | 1 | 5 |
FlinkKinesisProducer.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink |
247 | 16 | 5 |
ShardConsumer.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals |
134 | 7 | 4 |
KinesisStreamShard.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/model |
67 | 8 | 3 |
KinesisProxyV2Factory.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/proxy |
30 | 2 | 3 |
FanOutShardSubscriber.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout |
318 | 27 | 3 |
PollingRecordPublisher.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/polling |
114 | 6 | 3 |
AdaptivePollingRecordPublisher.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/polling |
55 | 2 | 3 |
FanOutRecordPublisherFactory.java in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/publisher/fanout |
43 | 3 | 2 |