spotify / DataflowJavaSDKConditional 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 4,508 units with 33,772 lines of code in units (65.8% of code).

0 very complex units (0 lines of code)
0 complex units (0 lines of code)
33 medium complex units (1,982 lines of code)
138 simple units (4,270 lines of code)
4,337 very simple units (27,520 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 insertAll() in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/BigQueryTableInserter.java	95	22	3
private static Map parseObjects() in sdk/src/main/java/com/google/cloud/dataflow/sdk/options/PipelineOptionsFactory.java	92	21	3
private void checkIndexedRecord() in sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/AvroCoder.java	61	21	3
public void processElement() in sdk/src/main/java/com/google/cloud/dataflow/sdk/io/PubsubIO.java	84	19	1
public Object invoke() in sdk/src/main/java/com/google/cloud/dataflow/sdk/options/ProxyInvocationHandler.java	35	18	3
public PDone apply() in sdk/src/main/java/com/google/cloud/dataflow/sdk/io/BigQueryIO.java	43	17	1
private static List validateClass() in sdk/src/main/java/com/google/cloud/dataflow/sdk/options/PipelineOptionsFactory.java	104	16	3
public void processElement() in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GroupAlsoByWindowsAndCombineDoFn.java	65	16	1
private long getFirstOccurenceOfRecordElement() in sdk/src/main/java/com/google/cloud/dataflow/sdk/io/XmlSource.java	85	16	2
public DataflowPipelineJob run() in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRunner.java	101	16	1
public long readSignedNumIncreasing() in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/OrderedCode.java	58	16	0
private void consumeResponse() in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/WindmillStateReader.java	67	16	3
private void doCheck() in sdk/src/main/java/com/google/cloud/dataflow/sdk/coders/AvroCoder.java	35	15	3
private void process() in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/StreamingDataflowWorker.java	151	15	4
static WorkItemStatus buildStatus() in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/DataflowWorker.java	71	15	11
private static Optional getDefaultValueFromAnnotation() in sdk/src/main/java/com/google/cloud/dataflow/sdk/options/PipelineOptionsFactory.java	30	14	1
private Object getDefault() in sdk/src/main/java/com/google/cloud/dataflow/sdk/options/ProxyInvocationHandler.java	33	14	2
static String globToRegexp() in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GcsUtil.java	34	14	1
DataflowPipelineJob run() in sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/TestDataflowPipelineRunner.java	72	14	2
public synchronized boolean tryReturnRecordAt() in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/GroupingShuffleRangeTracker.java	46	14	2
static List stageClasspathElements() in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/PackageUtil.java	88	13	3
public void onTimer() in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ReduceFnRunner.java	37	13	1
Optional checkForSuccess() in sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/TestDataflowPipelineRunner.java	41	13	1
private boolean doWork() in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/DataflowWorker.java	74	13	1
void setCredentialFactoryClass() in sdk/src/main/java/com/google/cloud/dataflow/sdk/options/GcpOptions.java	59	12	1
public void update() in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/OutputObjectAndByteCounter.java	22	12	1
private void processElement() in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ReduceFnRunner.java	47	12	3
public Coder getDefaultOutputCoder() in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/Create.java	44	12	1
public static DataflowPipelineRunner fromOptions() in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRunner.java	62	12	1
private void addExposedTypes() in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ApiSurface.java	30	11	2
public void process() in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/MonitoringUtil.java	32	11	1
public Table getOrCreateTable() in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/BigQueryTableInserter.java	45	11	4
private Set getReadyWindows() in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/StreamingSideInputDoFnRunner.java	39	11	0
static boolean printHelpUsageAndExitIfNeeded() in sdk/src/main/java/com/google/cloud/dataflow/sdk/options/PipelineOptionsFactory.java	50	10	3
public static StateNamespace fromString() in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/StateNamespaces.java	27	10	2
public boolean equals() in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/ShuffleEntry.java	17	10	1
protected void runReadLoop() in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/ReadOperation.java	50	10	0
public static MetricUpdate extractCounter() in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/CloudCounterUtils.java	44	10	2
public void processElement() in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GroupAlsoByWindowsViaIteratorsDoFn.java	39	10	1
public void validate() in sdk/src/main/java/com/google/cloud/dataflow/sdk/io/BigQueryIO.java	24	10	1
public static void assertSplitAtFractionExhaustive() in sdk/src/main/java/com/google/cloud/dataflow/sdk/testing/SourceTestUtils.java	50	10	2
public TriggerResult onElement() in sdk/src/main/java/com/google/cloud/dataflow/sdk/transforms/windowing/AfterWatermark.java	35	10	1
public Job translate() in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineTranslator.java	52	10	1
private void initCoder() in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ShuffleSink.java	60	10	1
public ParDoFn create() in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/NormalParDoFn.java	54	10	10
public static Source createSourceFromDictionary() in sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/ConcatReaderFactory.java	39	10	1
public ArrayList getJobMessages() in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/MonitoringUtil.java	32	9	2
public List expand() in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GcsUtil.java	48	9	1
public boolean equals() in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/WindowingStrategy.java	15	9	1
public boolean equals() in sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/Counter.java	20	9	1