apache / doris-spark-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 222 units with 2,104 lines of code in units (65.8% of code).

1 very complex units (167 lines of code)
1 complex units (33 lines of code)
4 medium complex units (165 lines of code)
20 simple units (538 lines of code)
196 very simple units (1,201 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 void convertArrowToRowBatch() in spark-doris-connector/src/main/java/org/apache/doris/spark/serialization/RowBatch.java	167	54	0
def getCatalystType() in spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/SchemaUtils.scala	33	28	3
def quote() in spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/Utils.scala	33	16	1
def params() in spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/Utils.scala	46	15	3
override def onJobEnd() in spark-doris-connector/src/main/scala/org/apache/doris/spark/listener/DorisTransactionListener.scala	43	11	1
def write() in spark-doris-connector/src/main/scala/org/apache/doris/spark/writer/DorisWriter.scala	43	11	1
private List parseLoadData() in spark-doris-connector/src/main/java/org/apache/doris/spark/load/DorisStreamLoad.java	33	10	2
public boolean equals() in spark-doris-connector/src/main/java/org/apache/doris/spark/rest/PartitionDefinition.java	15	9	1
public TScanBatchResult getNext() in spark-doris-connector/src/main/java/org/apache/doris/spark/backend/BackendClient.java	35	8	1
public void commit() in spark-doris-connector/src/main/java/org/apache/doris/spark/load/DorisStreamLoad.java	37	8	1
public boolean equals() in spark-doris-connector/src/main/java/org/apache/doris/spark/rest/models/Field.java	14	8	1
public int compareTo() in spark-doris-connector/src/main/java/org/apache/doris/spark/rest/PartitionDefinition.java	33	8	1
public RowBatch() in spark-doris-connector/src/main/java/org/apache/doris/spark/serialization/RowBatch.java	34	7	2
private void open() in spark-doris-connector/src/main/java/org/apache/doris/spark/backend/BackendClient.java	29	7	0
public TScanOpenResult openScanner() in spark-doris-connector/src/main/java/org/apache/doris/spark/backend/BackendClient.java	32	7	1
public void closeScanner() in spark-doris-connector/src/main/java/org/apache/doris/spark/backend/BackendClient.java	31	7	1
public DorisStreamLoad() in spark-doris-connector/src/main/java/org/apache/doris/spark/load/DorisStreamLoad.java	26	7	1
public boolean equals() in spark-doris-connector/src/main/java/org/apache/doris/spark/rest/models/Tablet.java	13	7	1
private static String send() in spark-doris-connector/src/main/java/org/apache/doris/spark/rest/RestService.java	52	7	3
private def escapeSql() in spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/Utils.scala	9	7	1
def convertToStruct() in spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/SchemaUtils.scala	23	7	3
public List loadV2() in spark-doris-connector/src/main/java/org/apache/doris/spark/load/DorisStreamLoad.java	18	6	3
public void abort() in spark-doris-connector/src/main/java/org/apache/doris/spark/load/DorisStreamLoad.java	31	6	1
public boolean equals() in spark-doris-connector/src/main/java/org/apache/doris/spark/rest/models/QueryPlan.java	12	6	1
public static Schema parseSchema() in spark-doris-connector/src/main/java/org/apache/doris/spark/rest/RestService.java	31	6	2
static QueryPlan getQueryPlan() in spark-doris-connector/src/main/java/org/apache/doris/spark/rest/RestService.java	30	6	2
public Properties asProperties() in spark-doris-connector/src/main/java/org/apache/doris/spark/cfg/SparkSettings.java	17	5	0
public Settings merge() in spark-doris-connector/src/main/java/org/apache/doris/spark/cfg/Settings.java	14	5	1
private HttpPut getHttpPut() in spark-doris-connector/src/main/java/org/apache/doris/spark/load/DorisStreamLoad.java	20	5	3
public int load() in spark-doris-connector/src/main/java/org/apache/doris/spark/load/DorisStreamLoad.java	39	5	2
private String escapeString() in spark-doris-connector/src/main/java/org/apache/doris/spark/load/DorisStreamLoad.java	18	5	1
public boolean equals() in spark-doris-connector/src/main/java/org/apache/doris/spark/rest/models/Schema.java	11	5	1
static List parseBackend() in spark-doris-connector/src/main/java/org/apache/doris/spark/rest/RestService.java	26	5	2
public static List getBackendRows() in spark-doris-connector/src/main/java/org/apache/doris/spark/rest/RestService.java	23	5	2
static List parseBackendV2() in spark-doris-connector/src/main/java/org/apache/doris/spark/rest/RestService.java	26	5	2
override def buildScan() in spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/DorisRelation.scala	21	5	0
private static String generateSerializedResult() in spark-doris-connector/src/main/java/org/apache/doris/spark/util/ListUtils.java	16	4	2
public void close() in spark-doris-connector/src/main/java/org/apache/doris/spark/serialization/RowBatch.java	11	4	0
private void close() in spark-doris-connector/src/main/java/org/apache/doris/spark/backend/BackendClient.java	11	4	0
public Settings merge() in spark-doris-connector/src/main/java/org/apache/doris/spark/cfg/Settings.java	9	4	1
private static String parseResponse() in spark-doris-connector/src/main/java/org/apache/doris/spark/rest/RestService.java	17	4	2
public static List findPartitions() in spark-doris-connector/src/main/java/org/apache/doris/spark/rest/RestService.java	37	4	2
static int tabletCountLimitForOnePartition() in spark-doris-connector/src/main/java/org/apache/doris/spark/rest/RestService.java	17	4	2
override def insert() in spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/DorisRelation.scala	12	4	2
public static String propsToString() in spark-doris-connector/src/main/java/org/apache/doris/spark/util/IOUtils.java	11	3	1
public static Properties propsFromString() in spark-doris-connector/src/main/java/org/apache/doris/spark/util/IOUtils.java	11	3	1
public static void divideAndSerialize() in spark-doris-connector/src/main/java/org/apache/doris/spark/util/ListUtils.java	14	3	3
private void parseRouting() in spark-doris-connector/src/main/java/org/apache/doris/spark/serialization/Routing.java	15	3	1
public String getProperty() in spark-doris-connector/src/main/java/org/apache/doris/spark/cfg/SparkSettings.java	7	3	1
public Integer getIntegerProperty() in spark-doris-connector/src/main/java/org/apache/doris/spark/cfg/Settings.java	10	3	2