apache / geode-kafka-connectorConditional 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 104 units with 752 lines of code in units (38.7% of code).

0 very complex units (0 lines of code)
0 complex units (0 lines of code)
0 medium complex units (0 lines of code)
3 simple units (60 lines of code)
101 very simple units (692 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 ClientCache createClientCache() in src/main/java/org/apache/geode/kafka/GeodeContext.java	27	7	7
void recreateEventBufferIfNeeded() in src/main/java/org/apache/geode/kafka/source/SharedEventBufferSupplier.java	13	6	1
public void onEvent() in src/main/java/org/apache/geode/kafka/source/GeodeKafkaSourceListener.java	20	6	1
private void updateBatchRecordsForRecord() in src/main/java/org/apache/geode/kafka/sink/GeodeKafkaSinkTask.java	17	5	3
public void start() in src/main/java/org/apache/geode/kafka/source/GeodeKafkaSourceTask.java	35	4	1
public List poll() in src/main/java/org/apache/geode/kafka/source/GeodeKafkaSourceTask.java	18	4	0
public void start() in src/main/java/org/apache/geode/kafka/sink/GeodeKafkaSinkTask.java	23	4	1
public GeodeConnectorConfig() in src/main/java/org/apache/geode/kafka/GeodeConnectorConfig.java	12	3	2
void installOnGeode() in src/main/java/org/apache/geode/kafka/source/GeodeKafkaSourceTask.java	12	3	5
GeodeKafkaSourceListener installListenersToRegion() in src/main/java/org/apache/geode/kafka/source/GeodeKafkaSourceTask.java	30	3	7
public String getSecurityClientAuthInit() in src/main/java/org/apache/geode/kafka/GeodeConnectorConfig.java	3	2	0
public String getSecurityPassword() in src/main/java/org/apache/geode/kafka/GeodeConnectorConfig.java	3	2	0
public boolean usesSecurity() in src/main/java/org/apache/geode/kafka/GeodeConnectorConfig.java	3	2	0
public void configure() in src/main/java/org/apache/geode/kafka/converter/JsonPdxConverter.java	5	2	2
public GeodeSourceConnectorConfig() in src/main/java/org/apache/geode/kafka/source/GeodeSourceConnectorConfig.java	16	2	1
void put() in src/main/java/org/apache/geode/kafka/sink/GeodeKafkaSinkTask.java	11	2	2
private void updateBatchForRegionByTopic() in src/main/java/org/apache/geode/kafka/sink/GeodeKafkaSinkTask.java	7	2	2
private Region createProxyRegion() in src/main/java/org/apache/geode/kafka/sink/GeodeKafkaSinkTask.java	8	2	1
public void addRemoveOperation() in src/main/java/org/apache/geode/kafka/sink/BatchRecords.java	7	2	1
public void addUpdateOperation() in src/main/java/org/apache/geode/kafka/sink/BatchRecords.java	6	2	2
public void executeOperations() in src/main/java/org/apache/geode/kafka/sink/BatchRecords.java	8	2	1
public static EnumRecommender in() in src/main/java/org/apache/geode/kafka/utils/EnumRecommender.java	7	2	1
public static EnumValidator in() in src/main/java/org/apache/geode/kafka/utils/EnumValidator.java	7	2	1
public void ensureValid() in src/main/java/org/apache/geode/kafka/utils/EnumValidator.java	5	2	2
static in src/main/java/org/apache/geode/kafka/Version.java	11	2	0
public CqQuery newCq() in src/main/java/org/apache/geode/kafka/GeodeContext.java	10	2	4
public CqResults newCqWithInitialResults() in src/main/java/org/apache/geode/kafka/GeodeContext.java	10	2	4
protected GeodeConnectorConfig() in src/main/java/org/apache/geode/kafka/GeodeConnectorConfig.java	4	1	0
protected static ConfigDef configurables() in src/main/java/org/apache/geode/kafka/GeodeConnectorConfig.java	55	1	0
public static List parseBindings() in src/main/java/org/apache/geode/kafka/GeodeConnectorConfig.java	8	1	1
public static List parseStringByComma() in src/main/java/org/apache/geode/kafka/GeodeConnectorConfig.java	3	1	1
public static List parseStringBy() in src/main/java/org/apache/geode/kafka/GeodeConnectorConfig.java	3	1	2
public static String reconstructString() in src/main/java/org/apache/geode/kafka/GeodeConnectorConfig.java	3	1	1
List parseLocators() in src/main/java/org/apache/geode/kafka/GeodeConnectorConfig.java	6	1	1
private LocatorHostPort parseLocator() in src/main/java/org/apache/geode/kafka/GeodeConnectorConfig.java	6	1	1
public int getTaskId() in src/main/java/org/apache/geode/kafka/GeodeConnectorConfig.java	3	1	0
public List getLocatorHostPorts() in src/main/java/org/apache/geode/kafka/GeodeConnectorConfig.java	3	1	0
public String getSecurityUserName() in src/main/java/org/apache/geode/kafka/GeodeConnectorConfig.java	3	1	0
public SchemaAndValue toConnectData() in src/main/java/org/apache/geode/kafka/converter/JsonPdxConverter.java	3	1	2
boolean shouldAddTypeAnnotation() in src/main/java/org/apache/geode/kafka/converter/JsonPdxConverter.java	3	1	0
public Map getInternalConfig() in src/main/java/org/apache/geode/kafka/converter/JsonPdxConverter.java	3	1	0
public Properties getCredentials() in src/main/java/org/apache/geode/kafka/security/SystemPropertyAuthInit.java	7	1	3
public Class taskClass() in src/main/java/org/apache/geode/kafka/source/GeodeKafkaSource.java	3	1	0
public ConfigDef config() in src/main/java/org/apache/geode/kafka/source/GeodeKafkaSource.java	3	1	0
public void start() in src/main/java/org/apache/geode/kafka/source/GeodeKafkaSource.java	3	1	1
public void stop() in src/main/java/org/apache/geode/kafka/source/GeodeKafkaSource.java	2	1	0
public String version() in src/main/java/org/apache/geode/kafka/source/GeodeKafkaSource.java	3	1	0
public SharedEventBufferSupplier() in src/main/java/org/apache/geode/kafka/source/SharedEventBufferSupplier.java	3	1	1
public BlockingQueue get() in src/main/java/org/apache/geode/kafka/source/SharedEventBufferSupplier.java	3	1	0
public GeodeKafkaSourceListener() in src/main/java/org/apache/geode/kafka/source/GeodeKafkaSourceListener.java	5	1	2