apache / flume-kafkaConditional 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 66 units with 964 lines of code in units (64.5% of code).

0 very complex units (0 lines of code)
1 complex units (148 lines of code)
6 medium complex units (376 lines of code)
1 simple units (33 lines of code)
58 very simple units (407 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 Status process() in flume-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java	148	31	0
protected Status doProcess() in flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java	113	25	0
protected void doConfigure() in flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java	45	16	1
protected void doCommit() in flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java	68	14	0
public void configure() in flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java	39	12	1
protected Event doTake() in flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java	62	12	0
public void configure() in flume-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java	49	12	1
protected void doPut() in flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java	33	8	1
private void setConsumerProps() in flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java	15	4	1
public void onCompletion() in flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java	12	4	2
public void onCompletion() in flume-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java	13	4	2
protected void doStop() in flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java	10	3	0
private Map getZookeeperOffsets() in flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java	15	3	3
public void stop() in flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java	13	3	0
private void setProducerProps() in flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java	12	3	2
private void setConsumerProps() in flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java	14	3	2
protected void doRollback() in flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java	13	3	0
private Event deserializeValue() in flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java	18	3	2
private String getCommittedOffsetsString() in flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java	14	3	0
private void setProducerProps() in flume-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java	12	3	2
private static void addGlobalSSLParameter() in flume-shared/flume-shared-kafka/src/main/java/org/apache/flume/shared/kafka/KafkaSSLUtil.java	6	3	3
public static boolean isSSLEnabled() in flume-shared/flume-shared-kafka/src/main/java/org/apache/flume/shared/kafka/KafkaSSLUtil.java	7	3	1
private static Map toStringMap() in flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java	7	2	1
public void onPartitionsRevoked() in flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java	6	2	1
public void onPartitionsAssigned() in flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java	5	2	1
public void start() in flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java	11	2	0
private synchronized ConsumerAndRecords createConsumerAndRecords() in flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java	14	2	0
void registerThread() in flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java	8	2	0
private static Map toCharSeqMap() in flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java	8	2	1
private static Map toStringMap() in flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java	7	2	1
private void poll() in flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java	10	2	0
private void commitOffsets() in flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java	10	2	0
private String getOffsetMapString() in flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java	9	2	0
private void saveOffsets() in flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java	6	2	2
public void onPartitionsRevoked() in flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java	6	2	1
public void onPartitionsAssigned() in flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java	5	2	1
public synchronized void start() in flume-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java	9	2	0
private static Map toCharSeqMap() in flume-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java	7	2	1
public static void addGlobalSSLParameters() in flume-shared/flume-shared-kafka/src/main/java/org/apache/flume/shared/kafka/KafkaSSLUtil.java	16	2	1
public long getBatchSize() in flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java	3	1	0
public T get() in flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java	3	1	0
public TopicListSubscriber() in flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java	3	1	1
public void subscribe() in flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java	3	1	2
public List get() in flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java	3	1	0
public PatternSubscriber() in flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java	3	1	1
public void subscribe() in flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java	3	1	2
public Pattern get() in flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java	3	1	0
String getBootstrapServers() in flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java	3	1	0
Properties getConsumerProps() in flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java	3	1	0
Subscriber getSubscriber() in flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java	3	1	0