spotify / flinkConditional 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 51,351 units with 436,915 lines of code in units (66.0% of code).

20 very complex units (4,224 lines of code)
148 complex units (12,797 lines of code)
770 medium complex units (38,765 lines of code)
1,966 simple units (57,204 lines of code)
48,447 very simple units (323,925 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 def translateCall() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/expressions/PlannerExpressionConverter.scala	545	167	2
private boolean visit() in flink-optimizer/src/main/java/org/apache/flink/optimizer/plandump/PlanJSONDumpGenerator.java	358	113	3
private def createFlinkAggFunction() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala	246	109	4
def generateCallExpression() in flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/StringCallGen.scala	114	94	4
private def convertTo() in flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/utils/python/PythonTableUtils.scala	156	87	1
private def convertTo() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/util/python/PythonTableUtils.scala	127	77	1
override def visitLocalRef() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala	242	75	1
def generateCast() in flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/ScalarOperatorGens.scala	329	73	3
override def visitOver() in flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/ExprCodeGenerator.scala	253	72	1
private TableResult executeOperation() in flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java	315	66	1
private static void validateInfo() in flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java	145	63	3
public static TypeInformation convertParquetTypeToTypeInfo() in flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/ParquetSchemaConverter.java	191	57	1
def getColumnInterval() in flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdColumnInterval.scala	186	56	3
private Resource loadResource() in flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java	209	55	3
private ApplicationReport startAppMaster() in flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java	317	54	7
public static DataFormatConverter getConverterForDataType() in flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/data/util/DataFormatConverters.java	155	53	1
public boolean equals() in flink-core/src/main/java/org/apache/flink/api/java/tuple/Tuple25.java	86	53	1
def canCast() in flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/typeutils/TypeCoercion.scala	44	52	2
public void costOperator() in flink-optimizer/src/main/java/org/apache/flink/optimizer/costs/CostEstimator.java	123	52	1
public boolean equals() in flink-core/src/main/java/org/apache/flink/api/java/tuple/Tuple24.java	83	51	1
private def estimateNumericComparison() in flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/metadata/SelectivityEstimator.scala	110	50	3
def visit() in flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkChangelogModeInferenceProgram.scala	177	49	2
public boolean equals() in flink-core/src/main/java/org/apache/flink/api/java/tuple/Tuple23.java	80	49	1
private def executeOperation() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/internal/TableEnvImpl.scala	169	48	1
private def translateCall() in flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/PlannerExpressionConverter.scala	179	47	3
private def parameterClassEquals() in flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/functions/utils/UserDefinedFunctionUtils.scala	37	47	2
public boolean equals() in flink-core/src/main/java/org/apache/flink/api/java/tuple/Tuple22.java	77	47	1
def toLogicalType() in flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/calcite/FlinkTypeFactory.scala	86	46	1
private static ColumnStatisticsData getColumnStatisticsData() in flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/util/HiveStatsUtil.java	128	46	3
public boolean equals() in flink-core/src/main/java/org/apache/flink/api/java/tuple/Tuple21.java	74	45	1
static in flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/PartitionPathUtils.java	200	43	0
def _create_type_verifier() in flink-python/pyflink/table/types.py	129	43	2
public boolean equals() in flink-core/src/main/java/org/apache/flink/api/java/tuple/Tuple20.java	71	43	1
public boolean equals() in flink-core/src/main/java/org/apache/flink/api/java/tuple/Tuple19.java	68	41	1
private void doRun() in flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java	194	41	0
private def createArray() in flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/utils/python/PythonTableUtils.scala	146	40	4
private def createArray() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/util/python/PythonTableUtils.scala	146	40	4
protected void doEndElement() in flink-filesystems/flink-s3-fs-base/src/main/java/com/amazonaws/services/s3/model/transform/XmlResponsesSaxParser.java	105	40	3
def createFieldTypeFromLogicalType() in flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/calcite/FlinkTypeFactory.scala	86	39	1
public void unionFields() in flink-core/src/main/java/org/apache/flink/types/Record.java	130	39	1
public boolean equals() in flink-core/src/main/java/org/apache/flink/api/java/tuple/Tuple18.java	65	39	1
public void go() in flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/UnilateralSortMerger.java	159	39	0
protected UnilateralSortMerger() in flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/UnilateralSortMerger.java	146	38	14
public void go() in flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/CombiningUnilateralSortMerger.java	163	38	0
private void callCommand() in flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliClient.java	113	37	1
override def visitCall() in flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/FlinkRelMdUtil.scala	71	37	1
private DataType fromJDBCType() in flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/PostgresCatalog.java	80	37	2
public List getAlternativePlans() in flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/BinaryUnionNode.java	134	37	1
private Resource loadResource() in flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java	130	37	3
public boolean equals() in flink-core/src/main/java/org/apache/flink/api/java/tuple/Tuple17.java	62	37	1