apache / flink - 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 67,527 units with 610,883 lines of code in units (66.1% of code).

16 very complex units (3,299 lines of code)
123 complex units (11,929 lines of code)
792 medium complex units (45,940 lines of code)
2,399 simple units (76,870 lines of code)
64,197 very simple units (472,845 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
def generateCallExpression() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/calls/StringCallGen.scala	134	96	4
override def visitOver() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/ExprCodeGenerator.scala	287	86	1
private static Function converter() in flink-python/src/main/java/org/apache/flink/streaming/api/utils/PythonTypeUtils.java	294	83	2
private static Function converter() in flink-python/src/main/java/org/apache/flink/table/utils/python/PythonTableUtils.java	257	76	1
private SqlNode registerFrom() in flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql/validate/SqlValidatorImpl.java	359	73	9
private static void validateInfo() in flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java	189	63	3
override def explain_() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/RelTreeWriterImpl.scala	163	60	3
def visit() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkChangelogModeInferenceProgram.scala	242	59	2
public static DataFormatConverter getConverterForDataType() in flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/data/util/DataFormatConverters.java	179	56	1
def getColumnInterval() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdColumnInterval.scala	213	56	3
def createAggFunction() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/AggFunctionFactory.scala	83	55	2
private static LogicalType toLogicalTypeNotNull() in flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/typeutils/LogicalRelDataTypeConverter.java	125	54	2
public boolean equals() in flink-core-api/src/main/java/org/apache/flink/api/java/tuple/Tuple25.java	86	53	1
def visit() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkChangelogModeInferenceProgram.scala	228	53	3
private ApplicationReport startAppMaster() in flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java	377	53	7
public boolean equals() in flink-core-api/src/main/java/org/apache/flink/api/java/tuple/Tuple24.java	83	51	1
def toLogicalType() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/calcite/FlinkTypeFactory.scala	97	50	1
private def estimateNumericComparison() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/metadata/SelectivityEstimator.scala	114	50	3
public boolean equals() in flink-core-api/src/main/java/org/apache/flink/api/java/tuple/Tuple23.java	80	49	1
private def validate() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/calcite/FlinkPlannerImpl.scala	83	49	2
public static Object toFlinkInternalValue() in flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/utils/RexLiteralUtil.java	116	49	2
public static Schema convertToSchema() in flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSchemaConverter.java	148	48	3
def _from_java_type() in flink-python/pyflink/common/typeinfo.py	121	48	1
public boolean equals() in flink-core-api/src/main/java/org/apache/flink/api/java/tuple/Tuple22.java	77	47	1
private def parameterClassEquals() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/functions/utils/UserDefinedFunctionUtils.scala	35	47	2
public RexNode convertExpression() in flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql2rel/SqlToRelConverter.java	157	47	1
def createFieldTypeFromLogicalType() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/calcite/FlinkTypeFactory.scala	102	46	1
public boolean equals() in flink-core-api/src/main/java/org/apache/flink/api/java/tuple/Tuple21.java	74	45	1
def visit() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkChangelogModeInferenceProgram.scala	185	45	2
private static Optional convertValidatedSqlNode() in flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/SqlNodeToOperationConversion.java	109	45	3
def _create_type_verifier() in flink-python/pyflink/table/types.py	137	45	2
private static boolean parameterClassEquals() in flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/LegacyUserDefinedFunctionInference.java	28	44	2
public boolean equals() in flink-core-api/src/main/java/org/apache/flink/api/java/tuple/Tuple20.java	71	43	1
def _to_java_data_type() in flink-python/pyflink/table/types.py	112	43	1
def _accumulate() in flink-python/pyflink/datastream/data_stream.py	70	42	4
public boolean equals() in flink-core-api/src/main/java/org/apache/flink/api/java/tuple/Tuple19.java	68	41	1
private WritableColumnVector fillColumnVector() in flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/vector/reader/NestedPrimitiveColumnReader.java	134	41	2
def getExpressionString() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/FlinkRexUtil.scala	103	40	5
protected void doEndElement() in flink-filesystems/flink-s3-fs-base/src/main/java/com/amazonaws/services/s3/model/transform/XmlResponsesSaxParser.java	94	40	3
public boolean equals() in flink-core-api/src/main/java/org/apache/flink/api/java/tuple/Tuple18.java	65	39	1
private void findSubQueries() in flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql2rel/SqlToRelConverter.java	94	39	5
public void unionFields() in flink-core/src/main/java/org/apache/flink/types/Record.java	150	39	1
private void substituteSubQuery() in flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql2rel/SqlToRelConverter.java	205	38	2
def _from_java_data_type() in flink-python/pyflink/table/types.py	119	38	1
public boolean equals() in flink-core-api/src/main/java/org/apache/flink/api/java/tuple/Tuple17.java	62	37	1
public String asSerializableString() in flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/ValueLiteralExpression.java	101	37	1
override def visitCall() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/FlinkRelMdUtil.scala	75	37	1
private static DataType convertToDataType() in flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSchemaConverter.java	106	37	2
protected void doEndElement() in flink-filesystems/flink-s3-fs-base/src/main/java/com/amazonaws/services/s3/model/transform/XmlResponsesSaxParser.java	117	36	3
public static WritableColumnVector createWritableColumnVector() in flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/vector/ParquetSplitReaderUtil.java	189	36	5