spotify / beamConditional 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 35,732 units with 301,656 lines of code in units (60.6% of code).

6 very complex units (3,269 lines of code)
38 complex units (5,202 lines of code)
425 medium complex units (23,651 lines of code)
1,350 simple units (40,256 lines of code)
33,913 very simple units (229,278 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
func file_beam_fn_api_proto_init() in sdks/go/pkg/beam/model/fnexecution_v1/beam_fn_api.pb.go	701	162	0
void apply() in buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy	1523	108	1
func file_beam_job_api_proto_init() in sdks/go/pkg/beam/model/jobmanagement_v1/beam_job_api.pb.go	318	75	0
func file_beam_artifact_api_proto_init() in sdks/go/pkg/beam/model/jobmanagement_v1/beam_artifact_api.pb.go	266	60	0
func file_schema_proto_init() in sdks/go/pkg/beam/model/pipeline_v1/schema.pb.go	257	54	0
func() in sdks/go/pkg/beam/core/runtime/exec/translate.go	204	51	1
func() in sdks/go/pkg/beam/core/runtime/graphx/coder.go	164	46	1
func() in sdks/go/pkg/beam/core/runtime/graphx/translate.go	201	44	1
public boolean equals() in sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkConfiguration.java	134	44	1
func file_v1_proto_init() in sdks/go/pkg/beam/core/runtime/graphx/v1/v1.pb.go	182	42	0
def _apply_deferred_ops() in sdks/python/apache_beam/dataframe/transforms.py	180	42	6
public void overrideFromOptions() in sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkConfiguration.java	125	42	1
public Node apply() in runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/CreateExecutableStageNodeFunction.java	298	42	1
func() in sdks/go/pkg/beam/core/runtime/exec/fn_arity.go	184	40	1
Convert createConverter() in sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoDynamicMessageSchema.java	74	40	1
public String toShortString() in sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkConfiguration.java	121	40	0
public DataflowPipelineJob run() in runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java	261	40	1
def pack_per_key_combiners() in sdks/python/apache_beam/runners/portability/fn_api_runner/translations.py	148	37	3
func encodeType() in sdks/go/pkg/beam/core/runtime/graphx/serialize.go	113	34	1
private static FieldType beamFieldTypeFromSingularProtoField() in sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoSchemaTranslator.java	96	34	1
public Node apply() in runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/RegisterNodeFunction.java	262	34	1
func nextParamState() in sdks/go/pkg/beam/core/funcx/fn.go	78	33	2
func decodeType() in sdks/go/pkg/beam/core/runtime/graphx/serialize.go	111	33	1
def run_pipeline() in sdks/python/apache_beam/runners/dataflow/dataflow_runner.py	101	33	3
def __init__() in sdks/python/apache_beam/runners/common.py	80	33	9
def create_job_resources() in sdks/python/apache_beam/runners/portability/stager.py	116	32	7
private static DoFnSignature parseSignature() in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignatures.java	310	32	1
long insertAll() in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java	167	32	12
private static Parameter analyzeExtraParameter() in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignatures.java	213	31	7
static Object toBeamObject() in sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamCalcRel.java	84	31	3
func AsDoFn() in sdks/go/pkg/beam/core/graph/fn.go	97	30	2
def infer_return_type_func() in sdks/python/apache_beam/typehints/trivial_inference.py	163	30	4
def generate_urn_files() in sdks/python/gen_protos.py	124	30	2
def run_Read() in sdks/python/apache_beam/runners/dataflow/dataflow_runner.py	107	29	3
def _try_split() in sdks/python/apache_beam/runners/common.py	104	28	10
public static Object convertAvroFormat() in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryUtils.java	74	28	3
func tryBindInbound() in sdks/go/pkg/beam/core/graph/bind.go	108	27	3
func() in sdks/go/pkg/beam/runners/dataflow/dataflowlib/translate.go	144	27	1
public static Object autoCastField() in sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/schema/BeamTableUtils.java	68	27	2
func inferCoder() in sdks/go/pkg/beam/coder.go	76	26	1
def groupby() in sdks/python/apache_beam/dataframe/frames.py	112	26	7
def _invoke_process_per_window() in sdks/python/apache_beam/runners/common.py	93	26	4
private static BeamFieldConverter jdbcTypeToBeamFieldConverter() in sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/SchemaUtil.java	57	26	1
private NexmarkPerf currentPerf() in sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkLauncher.java	72	26	6
func EncodeCoderRef() in sdks/go/pkg/beam/core/runtime/graphx/dataflow.go	86	25	1
func() in sdks/go/pkg/beam/core/runtime/harness/harness.go	169	25	1
func isConcrete() in sdks/go/pkg/beam/core/typex/class.go	52	25	2
def wrapper() in sdks/python/apache_beam/dataframe/frame_base.py	87	25	2
def get_or_create_table() in sdks/python/apache_beam/io/gcp/bigquery_tools.py	70	25	8
public ResultT match() in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignature.java	56	25	1