epam / TimeBaseKafkaConnectorConditional 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 108 units with 1,248 lines of code in units (78.4% of code).

0 very complex units (0 lines of code)
0 complex units (0 lines of code)
9 medium complex units (382 lines of code)
11 simple units (269 lines of code)
88 very simple units (597 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
private void writeStruct() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageSerializer.java	76	25	4
private DataType getDataType() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageSerializer.java	43	19	2
private void writeNull() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageSerializer.java	51	16	2
private void writeArray() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageSerializer.java	51	16	4
private Schema getPrimitiveTypeSchema() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageDeserializer.java	48	16	1
public RawMessage serialize() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageSerializer.java	24	12	2
private void validateDescriptor() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageDeserializer.java	19	12	1
private Struct buildStruct() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageDeserializer.java	40	12	3
public RawMessageSerializer() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageSerializer.java	30	11	3
public void start() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/TBSourceTask.java	47	10	1
private RawMessage nextMessage() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/TBSourceTask.java	23	9	1
private Schema buildSchema() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageDeserializer.java	25	9	1
public void put() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/TBSinkTask.java	19	8	1
private String buildKey() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageDeserializer.java	27	8	3
public Map getValues() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageDeserializer.java	20	8	1
private void addDataField() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageSerializer.java	23	7	4
private void resetToOffset() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/TBSourceTask.java	26	7	1
public List poll() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/TBSourceTask.java	19	7	0
private RecordClassDescriptor buildDescriptor() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageSerializer.java	25	6	1
public void addAlias() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/FieldMap.java	15	6	2
public static LogicalType getTypeByName() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/LogicalType.java	9	5	1
private int toInt32() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageSerializer.java	15	5	2
private long toInt64() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageSerializer.java	11	5	2
private void validateSourceFields() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageSerializer.java	11	5	2
private void validateNewFields() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageSerializer.java	12	5	2
private void validateNewField() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageSerializer.java	8	5	2
public FieldMap() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/FieldMap.java	12	5	2
public String makePathString() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/FieldMap.java	13	5	1
private void validateSchema() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageSerializer.java	12	4	1
private static void validateSchemaField() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageSerializer.java	9	4	3
public FieldSelection() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/FieldSelection.java	7	4	2
private static Set toSet() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/FieldSelection.java	9	4	1
public boolean isSelected() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/FieldSelection.java	4	4	1
public void start() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/TBSinkTask.java	13	4	1
public void flush() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/TBSinkTask.java	15	4	1
public Schema getFieldSchema() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageDeserializer.java	11	4	1
private Field getField() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageSerializer.java	7	3	2
private Object getFieldValue() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageSerializer.java	7	3	2
private static RecordClassDescriptor getDescriptor() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/TBSourceTask.java	7	3	2
public synchronized void stop() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/TBSourceTask.java	9	3	0
private Struct getLastRecord() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/TBSinkTask.java	13	3	0
private void initSerializer() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/TBSinkTask.java	10	3	1
private void send() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/TBSinkTask.java	14	3	1
public void stop() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/TBSinkTask.java	9	3	0
static final String normalize() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/TBConnectorConfig.java	3	3	1
public void start() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/TBSinkConnector.java	10	3	1
private Schema getObjectSchema() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageDeserializer.java	13	3	1
private Long getTimestamp() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageSerializer.java	6	2	2
private RecordClassDescriptor buildFieldDescriptor() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageSerializer.java	7	2	1
private FixedUnboundEncoder getEncoder() in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageSerializer.java	9	2	1