apache / pulsar-connectorsConditional Complexity

Intro

Conditional complexity (also called cyclomatic complexity) is a term used to measure the complexity of software. The term refers to the number of possible paths through a program function. A higher value ofter means higher maintenance and testing costs (infosecinstitute.com).
Conditional complexity is calculated by counting all conditions in the program that can affect the execution path (e.g. if statement, loops, switches, and/or operators, try and catch blocks...).
Conditional complexity is measured at the unit level (methods, functions...).
Units are classified in four categories based on the measured McCabe index: 1-5 (simple units), 6-10 (medium complex units), 11-25 (complex units), 26+ (very complex units).

Learn more...

Conditional Complexity Overall

There are 570 units with 5,971 lines of code in units (55.0% of code).

0 very complex units (0 lines of code)
0 complex units (0 lines of code)
11 medium complex units (600 lines of code)
42 simple units (1,261 lines of code)
517 very simple units (4,110 lines of code)

Legend:

51+

26-50

11-25

6-10

1-5

Alternative Visuals

3D view of all units

Conditional Complexity per Extension

51+

26-50

11-25

6-10

1-5

Conditional Complexity per Logical Component

primary logical decomposition

51+

26-50

11-25

6-10

1-5

Most Complex Units

Top 50 most complex units

Unit	# lines	McCabe index	# params
public static List messageConverter() in pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal/MessageUtils.java	83	21	1
public void validate() in pulsar-io/file/src/main/java/org/apache/pulsar/io/file/FileSourceConfig.java	37	20	0
private FileFilter createFileFilter() in pulsar-io/file/src/main/java/org/apache/pulsar/io/file/FileListingThread.java	47	18	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
final protected Point buildPoint() in pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v2/InfluxDBSink.java	51	12	1
private void startAllComponents() in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/Application.java	47	11	1
private void loadSources() in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/AbstractConfigurationProvider.java	86	11	3
private void flush() in pulsar-io/redis/src/main/java/org/apache/pulsar/io/redis/sink/RedisSink.java	43	11	0
public void bindValue() in pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/BaseJdbcAutoSchemaSink.java	37	11	3
protected void recoverRecords() in pulsar-io/debezium/core/src/main/java/org/apache/pulsar/io/debezium/PulsarDatabaseHistory.java	41	11	1
private void loadSinkGroups() in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/AbstractConfigurationProvider.java	59	10	3
public void run() in pulsar-io/file/src/main/java/org/apache/pulsar/io/file/FileListingThread.java	28	10	0
private static int createEncryptionCtxOffset() in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/Utils.java	48	9	2
public Status process() in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source/SinkOfFlume.java	53	9	0
private void stopAllComponents() in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/Application.java	35	9	0
private void loadSinks() in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/AbstractConfigurationProvider.java	60	9	3
private Set performListing() in pulsar-io/file/src/main/java/org/apache/pulsar/io/file/FileListingThread.java	26	9	3
public void validate() in pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/ElasticSearchConfig.java	15	9	0
public static ByteBuffer serializeRecordToFlatBuffer() in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/Utils.java	35	8	2
public static String serializeRecordToJson() in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/Utils.java	44	8	1
public void ack() in pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/AbstractKafkaConnectSource.java	29	8	0
public void StartConnector() in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/FlumeConnector.java	67	8	1
public MaterializedConfiguration getConfiguration() in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/AbstractConfigurationProvider.java	48	8	0
public void validate() in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/HdfsSinkConfig.java	20	8	0
private static Configuration getConfig() in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/AbstractHdfsConnector.java	23	8	2
private static Configuration getConfig() in pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/AbstractHdfsConnector.java	23	8	2
protected void process() in pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal/CanalAbstractSource.java	35	8	0
private static void setColumnValue() in pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/BaseJdbcAutoSchemaSink.java	20	8	3
public void open() in pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSource.java	42	8	2
private void checkpoint() in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisRecordProcessor.java	25	7	1
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 void stop() in pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/PulsarOffsetBackingStore.java	23	7	0
public Status doProcess() in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/sink/SourceOfFlume.java	28	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 validate() in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/AbstractHdfsConfig.java	9	7	0
public void validate() in pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/AbstractHdfsConfig.java	9	7	0
private void checkpoint() in pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/StreamsRecordProcessor.java	25	7	1
protected void channelRead0() in pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/http/NettyHttpServerHandler.java	22	7	2
public static TableDefinition getTableDefinition() in pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/JdbcUtils.java	38	7	4
private void initStatement() in pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/JdbcAbstractSink.java	20	7	0
protected Point buildPoint() in pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1/InfluxDBGenericRecordSink.java	38	7	1
private void flush() in pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/BatchSink.java	33	7	0
private void createClient() in pulsar-io/aerospike/src/main/java/org/apache/pulsar/io/aerospike/AerospikeAbstractSink.java	19	7	1
private void flush() in pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink/HbaseAbstractSink.java	33	7	0
public void write() in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSink.java	23	6	1
public KinesisRecord() in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisRecord.java	23	6	1
protected void process() in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source/AbstractSource.java	26	6	0
private void loadMonitoring() in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/Application.java	29	6	0
public void validate() in pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/HdfsSinkConfig.java	13	6	0