GoogleCloudPlatform / dataflow-metrics-exporter

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 157 units with 1,228 lines of code in units (62.3% of code).

0 very complex units (0 lines of code)
0 complex units (0 lines of code)
0 medium complex units (0 lines of code)
7 simple units (254 lines of code)
150 very simple units (974 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 static void validateTemplateLauncherConfig() in src/main/java/com/google/cloud/dfmetrics/utils/ConfigValidator.java	27	9	1
Map filterAndParseMetrics() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/MetricsManager.java	23	8	1
public void addComputedMetrics() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/MetricsManager.java	56	8	3
private Optional getWorkerTimeInterval() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/MetricsManager.java	27	8	0
public void load() in src/main/java/com/google/cloud/dfmetrics/output/BigqueryStore.java	52	7	2
private static ExecutionStatus finishOrTimeout() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/DataflowJobManager.java	35	6	3
public Double getMetricValue() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/MetricsManager.java	34	6	1
private static String validateForNulls() in src/main/java/com/google/cloud/dfmetrics/utils/ConfigValidator.java	14	5	1
public Job waitUntilActive() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/DataflowJobManager.java	29	4	0
private boolean jobIsDoneOrFinishing() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/DataflowJobManager.java	16	4	0
public void run() in src/main/java/com/google/cloud/dfmetrics/commands/TemplateLauncherCommand.java	53	4	0
public void load() in src/main/java/com/google/cloud/dfmetrics/output/FileStore.java	32	4	2
private boolean jobIsDone() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/DataflowJobManager.java	16	3	0
private static boolean allMatch() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/DataflowJobManager.java	9	3	1
private List extractValuesFromTimeSeriesAsDouble() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/MonitoringClient.java	9	3	1
public double estimateJobCost() in src/main/java/com/google/cloud/dfmetrics/model/ResourcePricing.java	20	3	2
public static Map castValuesToAppropriateTypes() in src/main/java/com/google/cloud/dfmetrics/utils/MetricsCollectorUtils.java	8	3	1
public static Command create() in src/main/java/com/google/cloud/dfmetrics/commands/CommandFactory.java	15	3	1
public static IOutputStore create() in src/main/java/com/google/cloud/dfmetrics/output/OutputStoreFactory.java	11	3	2
protected JobState handleJobState() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/DataflowJobManager.java	4	2	1
public ExecutionStatus waitForDurationAndCancelJob() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/DataflowJobManager.java	10	2	0
public MonitoringClient build() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/MonitoringClient.java	5	2	0
public Optional getJobElapsedTime() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/MonitoringClient.java	17	2	3
public static JobState parse() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/JobState.java	6	2	1
public static TemplateClient create() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/TemplateClient.java	6	2	2
private boolean isValidNames() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/MetricsManager.java	5	2	1
public Map getMetrics() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/MetricsManager.java	20	2	2
public Job launch() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/ClassicTemplateClient.java	27	2	3
private FlexTemplateRuntimeEnvironment buildEnvironment() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/FlexTemplateClient.java	10	2	1
public Dataflow build() in src/main/java/com/google/cloud/dfmetrics/model/DataflowClient.java	10	2	0
public static RetryPolicy clientRetryPolicy() in src/main/java/com/google/cloud/dfmetrics/utils/RetryUtil.java	13	2	0
public static String serializeToJson() in src/main/java/com/google/cloud/dfmetrics/utils/MetricsCollectorUtils.java	9	2	2
public static void printMap() in src/main/java/com/google/cloud/dfmetrics/utils/MetricsCollectorUtils.java	5	2	1
public static Credentials googleCredentials() in src/main/java/com/google/cloud/dfmetrics/utils/MetricsCollectorUtils.java	10	2	0
public static boolean validateMetricsFetcherConfig() in src/main/java/com/google/cloud/dfmetrics/utils/ConfigValidator.java	9	2	1
public void initialize() in src/main/java/com/google/cloud/dfmetrics/commands/TemplateLauncherCommand.java	13	2	0
JobConfig createJobConfig() in src/main/java/com/google/cloud/dfmetrics/commands/TemplateLauncherCommand.java	19	2	1
public void initialize() in src/main/java/com/google/cloud/dfmetrics/commands/MetricsFetcherCommand.java	10	2	0
public void run() in src/main/java/com/google/cloud/dfmetrics/commands/MetricsFetcherCommand.java	25	2	0
public static TableReference getTableReference() in src/main/java/com/google/cloud/dfmetrics/output/BigqueryStore.java	10	2	1
default void addIfValueExists() in src/main/java/com/google/cloud/dfmetrics/output/IOutputStore.java	5	2	3
public static Duration getDefaultTimeOut() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/DataflowJobManager.java	3	1	0
public static Builder builder() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/DataflowJobManager.java	5	1	1
public static Builder builder() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/DataflowJobManager.java	6	1	2
public DataflowJobManager withJob() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/DataflowJobManager.java	4	1	3
public DataflowJobManager withJob() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/DataflowJobManager.java	6	1	4
public DataflowJobManager withJob() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/DataflowJobManager.java	3	1	1
public JobState getLatestJobState() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/DataflowJobManager.java	3	1	0
public Job getLatestJobView() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/DataflowJobManager.java	10	1	0
public void printJobResponse() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/DataflowJobManager.java	7	1	0