apache / pulsar-connectorsUnit Size

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 570 units with 5,971 lines of code in units (55.0% of code).

0 very long units (0 lines of code)
10 long units (644 lines of code)
59 medium size units (1,840 lines of code)
112 small units (1,599 lines of code)
389 very small units (1,888 lines of code)

Legend:

101+

51-100

21-50

11-20

1-10

Unit Size per Extension

101+

51-100

21-50

11-20

1-10

Unit Size per Logical Component

primary logical decomposition

101+

51-100

21-50

11-20

1-10

Alternative Visuals

3D view of all units

Longest Units

Top 50 longest units

Unit	# lines	McCabe index	# params
private void loadSources() in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/AbstractConfigurationProvider.java	86	11	3
public static List messageConverter() in pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal/MessageUtils.java	83	21	1
public void StartConnector() in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/FlumeConnector.java	67	8	1
public abstract void bindValue() in pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/JdbcAbstractSink.java	67	14	3
private void loadChannels() in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/AbstractConfigurationProvider.java	61	13	2
private void loadSinks() in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/AbstractConfigurationProvider.java	60	9	3
private void loadSinkGroups() in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/AbstractConfigurationProvider.java	59	10	3
public void open() in pulsar-io/mongo/src/main/java/org/apache/pulsar/io/mongodb/MongoSource.java	57	5	2
public Status process() in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source/SinkOfFlume.java	53	9	0
final protected Point buildPoint() in pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v2/InfluxDBSink.java	51	12	1
public void open() in pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/AbstractKafkaConnectSource.java	50	4	2
private static int createEncryptionCtxOffset() in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/Utils.java	48	9	2
public void open() in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSource.java	48	4	2
public MaterializedConfiguration getConfiguration() in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/AbstractConfigurationProvider.java	48	8	0
private void startAllComponents() in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/Application.java	47	11	1
private FileFilter createFileFilter() in pulsar-io/file/src/main/java/org/apache/pulsar/io/file/FileListingThread.java	47	18	1
private void startThread() in pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/TwitterFireHose.java	45	3	1
public static String serializeRecordToJson() in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/Utils.java	44	8	1
private void flush() in pulsar-io/redis/src/main/java/org/apache/pulsar/io/redis/sink/RedisSink.java	43	11	0
public void open() in pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSource.java	42	8	2
protected void recoverRecords() in pulsar-io/debezium/core/src/main/java/org/apache/pulsar/io/debezium/PulsarDatabaseHistory.java	41	11	1
public static RedisSession create() in pulsar-io/redis/src/main/java/org/apache/pulsar/io/redis/RedisSession.java	40	4	1
public void open() in pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/DynamoDBSource.java	40	3	2
public static TableDefinition getTableDefinition() in pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/JdbcUtils.java	38	7	4
protected Point buildPoint() in pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1/InfluxDBGenericRecordSink.java	38	7	1
public void validate() in pulsar-io/file/src/main/java/org/apache/pulsar/io/file/FileSourceConfig.java	37	20	0
public void bindValue() in pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/BaseJdbcAutoSchemaSink.java	37	11	3
public static ByteBuffer serializeRecordToFlatBuffer() in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/Utils.java	35	8	2
private void stopAllComponents() in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/Application.java	35	9	0
protected void process() in pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal/CanalAbstractSource.java	35	8	0
public void start() in pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSource.java	34	6	0
private void flush() in pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/BatchSink.java	33	7	0
private void flush() in pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink/HbaseAbstractSink.java	33	7	0
public FlumeConfiguration getFlumeConfiguration() in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/PropertiesFileConfigurationProvider.java	32	7	0
public void open() in pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/JdbcAbstractSink.java	30	4	2
public void ack() in pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/AbstractKafkaConnectSource.java	29	8	0
private void loadMonitoring() in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/Application.java	29	6	0
void readToEnd() in pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/PulsarOffsetBackingStore.java	28	4	1
public Status doProcess() in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/sink/SourceOfFlume.java	28	7	0
public void run() in pulsar-io/file/src/main/java/org/apache/pulsar/io/file/FileListingThread.java	28	10	0
private void flush() in pulsar-io/mongo/src/main/java/org/apache/pulsar/io/mongodb/MongoSink.java	28	5	0
public synchronized Record read() in pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/AbstractKafkaConnectSource.java	27	7	0
public Class getClassByNameOrNull() in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/AbstractHdfsConnector.java	27	5	1
public Class getClassByNameOrNull() in pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/AbstractHdfsConnector.java	27	5	1
protected void process() in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source/AbstractSource.java	26	6	0
private Set performListing() in pulsar-io/file/src/main/java/org/apache/pulsar/io/file/FileListingThread.java	26	9	3
public AwsCredentialProviderPlugin defaultCredentialProvider() in pulsar-io/aws/src/main/java/org/apache/pulsar/io/aws/AbstractAwsConnector.java	26	3	1
private void checkpoint() in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisRecordProcessor.java	25	7	1
private void checkpoint() in pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/StreamsRecordProcessor.java	25	7	1
public void write() in pulsar-io/solr/src/main/java/org/apache/pulsar/io/solr/SolrAbstractSink.java	25	5	1