apache / doris-kafka-connector - Conditional 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 547 units with 4,167 lines of code in units (68.9% of code).

0 very complex units (0 lines of code)
1 complex units (143 lines of code)
0 medium complex units (0 lines of code)
16 simple units (545 lines of code)
530 very simple units (3,479 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 String validateConfig() in src/main/java/org/apache/doris/kafka/connector/utils/ConfigCheckUtils.java	143	31	1
public void load() in src/main/java/org/apache/doris/kafka/connector/writer/load/DorisStreamLoad.java	56	10	2
public boolean equals() in src/main/java/org/apache/doris/kafka/connector/model/doris/Field.java	14	8	1
public static Map parseTopicToTableMap() in src/main/java/org/apache/doris/kafka/connector/utils/ConfigCheckUtils.java	29	8	1
public static boolean validateGroupCommitMode() in src/main/java/org/apache/doris/kafka/connector/utils/ConfigCheckUtils.java	27	8	1
public List extractColumnValuesBySQL() in src/main/java/org/apache/doris/kafka/connector/service/DorisSystemService.java	25	8	4
public DorisOptions() in src/main/java/org/apache/doris/kafka/connector/cfg/DorisOptions.java	73	7	1
private Map parseTopicSchemaPath() in src/main/java/org/apache/doris/kafka/connector/decode/avro/DorisAvroConverter.java	25	7	1
private static String send() in src/main/java/org/apache/doris/kafka/connector/service/RestService.java	81	7	3
private void commitTransaction() in src/main/java/org/apache/doris/kafka/connector/writer/commit/DorisCommitter.java	60	7	1
protected void insertRecord() in src/main/java/org/apache/doris/kafka/connector/writer/DorisWriter.java	24	7	1
private String parseFieldValues() in src/main/java/org/apache/doris/kafka/connector/converter/RecordService.java	30	7	4
public Object getValue() in src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/ArrayType.java	26	7	2
public Connection getOrEstablishConnection() in src/main/java/org/apache/doris/kafka/connector/connection/JdbcConnectionProvider.java	20	6	0
public static String generateValidName() in src/main/java/org/apache/doris/kafka/connector/utils/ConfigCheckUtils.java	16	6	2
private String parseRecordTableName() in src/main/java/org/apache/doris/kafka/connector/service/DorisDefaultSinkService.java	27	6	3
public boolean equals() in src/main/java/org/apache/doris/kafka/connector/writer/commit/DorisCommittable.java	12	6	1
public boolean equals() in src/main/java/org/apache/doris/kafka/connector/model/doris/Schema.java	10	5	1
public void parseTopic2Schema() in src/main/java/org/apache/doris/kafka/connector/decode/avro/DorisAvroConverter.java	43	5	1
private static List parseBackendV2() in src/main/java/org/apache/doris/kafka/connector/service/RestService.java	26	5	2
public void insert() in src/main/java/org/apache/doris/kafka/connector/service/DorisDefaultSinkService.java	14	5	1
public Map preCommit() in src/main/java/org/apache/doris/kafka/connector/DorisSinkTask.java	21	5	1
public boolean executeCopy() in src/main/java/org/apache/doris/kafka/connector/writer/load/CopyLoad.java	52	5	1
public boolean handleCommitResponse() in src/main/java/org/apache/doris/kafka/connector/writer/load/CopyLoad.java	23	5	1
public String getTypeName() in src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/ArrayType.java	19	5	1
public void ensureValid() in src/main/java/org/apache/doris/kafka/connector/cfg/DorisSinkConnectorConfig.java	10	4	2
public static Object backoffAndRetry() in src/main/java/org/apache/doris/kafka/connector/utils/BackoffAndRetryUtils.java	21	4	2
public SchemaAndValue toConnectData() in src/main/java/org/apache/doris/kafka/connector/decode/avro/DorisAvroConverter.java	23	4	2
public static List getBackendsV2() in src/main/java/org/apache/doris/kafka/connector/service/RestService.java	23	4	2
private static Map handleResponse() in src/main/java/org/apache/doris/kafka/connector/service/RestService.java	20	4	2
public boolean shouldSkipRecord() in src/main/java/org/apache/doris/kafka/connector/service/DorisDefaultSinkService.java	25	4	1
public void checkDorisTableKey() in src/main/java/org/apache/doris/kafka/connector/writer/StreamLoadWriter.java	10	4	1
public void fetchOffset() in src/main/java/org/apache/doris/kafka/connector/writer/StreamLoadWriter.java	16	4	0
public void fetchOffset() in src/main/java/org/apache/doris/kafka/connector/writer/CopyIntoWriter.java	16	4	0
public void commit() in src/main/java/org/apache/doris/kafka/connector/writer/commit/DorisCommitter.java	8	4	1
public void upLoadFile() in src/main/java/org/apache/doris/kafka/connector/writer/load/CopyLoad.java	33	4	3
public String getUploadAddress() in src/main/java/org/apache/doris/kafka/connector/writer/load/CopyLoad.java	43	4	1
public String processStructRecord() in src/main/java/org/apache/doris/kafka/connector/converter/RecordService.java	36	4	1
private void alterTableIfNeeded() in src/main/java/org/apache/doris/kafka/connector/converter/RecordService.java	25	4	2
public String getProcessedRecord() in src/main/java/org/apache/doris/kafka/connector/converter/RecordService.java	13	4	1
private void readSinkRecordNonKeyData() in src/main/java/org/apache/doris/kafka/connector/converter/RecordDescriptor.java	15	4	2
private Map handleResponse() in src/main/java/org/apache/doris/kafka/connector/converter/schema/SchemaChangeManager.java	20	4	2
public void closeConnection() in src/main/java/org/apache/doris/kafka/connector/connection/JdbcConnectionProvider.java	11	3	0
private Properties getStreamLoadPropFromConfig() in src/main/java/org/apache/doris/kafka/connector/cfg/DorisOptions.java	14	3	1
private static String readFromFileName() in src/main/java/org/apache/doris/kafka/connector/utils/FileNameUtils.java	13	3	2
private static boolean isNumeric() in src/main/java/org/apache/doris/kafka/connector/utils/ConfigCheckUtils.java	7	3	1
private static boolean validateEnumInstances() in src/main/java/org/apache/doris/kafka/connector/utils/ConfigCheckUtils.java	8	3	2
public String getAvailableBackend() in src/main/java/org/apache/doris/kafka/connector/utils/BackendUtils.java	11	3	0
private static String parseResponse() in src/main/java/org/apache/doris/kafka/connector/service/RestService.java	17	3	2
public void startTask() in src/main/java/org/apache/doris/kafka/connector/service/DorisDefaultSinkService.java	24	3	2