GoogleCloudPlatform / dataflow-metrics-exporter

Intro

Unit size measurements show the distribution of size of units of code (methods, functions...).
Units are classified in four categories based on their size (lines of code): 1-20 (small units), 20-50 (medium size units), 51-100 (long units), 101+ (very long units).
You should aim at keeping units small (< 20 lines). Long units may become "bloaters", code that have increased to such gargantuan proportions that they are hard to work with.

Learn more...

Unit Size Overall

There are 157 units with 1,228 lines of code in units (62.3% of code).

0 very long units (0 lines of code)
3 long units (161 lines of code)
10 medium size units (287 lines of code)
15 small units (230 lines of code)
129 very small units (550 lines of code)

Legend:

101+

51-100

21-50

11-20

1-10

Unit Size per Extension

101+

51-100

21-50

11-20

1-10

Unit Size per Logical Component

primary logical decomposition

101+

51-100

21-50

11-20

1-10

Alternative Visuals

3D view of all units

Longest Units

Top 50 longest units

Unit	# lines	McCabe index	# params
public void addComputedMetrics() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/MetricsManager.java	56	8	3
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/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
public void load() in src/main/java/com/google/cloud/dfmetrics/output/FileStore.java	32	4	2
public Job waitUntilActive() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/DataflowJobManager.java	29	4	0
public Job launch() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/FlexTemplateClient.java	28	1	3
private Optional getWorkerTimeInterval() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/MetricsManager.java	27	8	0
public Job launch() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/ClassicTemplateClient.java	27	2	3
public static void validateTemplateLauncherConfig() in src/main/java/com/google/cloud/dfmetrics/utils/ConfigValidator.java	27	9	1
public void run() in src/main/java/com/google/cloud/dfmetrics/commands/MetricsFetcherCommand.java	25	2	0
Map filterAndParseMetrics() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/MetricsManager.java	23	8	1
public Map getMetrics() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/MetricsManager.java	20	2	2
public double estimateJobCost() in src/main/java/com/google/cloud/dfmetrics/model/ResourcePricing.java	20	3	2
JobConfig createJobConfig() in src/main/java/com/google/cloud/dfmetrics/commands/TemplateLauncherCommand.java	19	2	1
public Optional getJobElapsedTime() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/MonitoringClient.java	17	2	3
private boolean jobIsDone() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/DataflowJobManager.java	16	3	0
private boolean jobIsDoneOrFinishing() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/DataflowJobManager.java	16	4	0
private List listMessages() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/MetricsManager.java	16	1	4
public static String logDataflowJob() in src/main/java/com/google/cloud/dfmetrics/utils/PrettyLogger.java	16	1	1
public static Command create() in src/main/java/com/google/cloud/dfmetrics/commands/CommandFactory.java	15	3	1
private static String validateForNulls() in src/main/java/com/google/cloud/dfmetrics/utils/ConfigValidator.java	14	5	1
public static RetryPolicy clientRetryPolicy() in src/main/java/com/google/cloud/dfmetrics/utils/RetryUtil.java	13	2	0
public void initialize() in src/main/java/com/google/cloud/dfmetrics/commands/TemplateLauncherCommand.java	13	2	0
public static void main() in src/main/java/com/google/cloud/dfmetrics/MetricsExporter.java	13	1	1
public Job cancelJob() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/DataflowJobManager.java	11	1	0
public static IOutputStore create() in src/main/java/com/google/cloud/dfmetrics/output/OutputStoreFactory.java	11	3	2
public Job getLatestJobView() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/DataflowJobManager.java	10	1	0
public ExecutionStatus waitForDurationAndCancelJob() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/DataflowJobManager.java	10	2	0
public Job drainJob() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/DataflowJobManager.java	10	1	0
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 Credentials googleCredentials() in src/main/java/com/google/cloud/dfmetrics/utils/MetricsCollectorUtils.java	10	2	0
public JobInfo getLaunchedJobInfo() in src/main/java/com/google/cloud/dfmetrics/commands/TemplateLauncherCommand.java	10	1	3
public void initialize() in src/main/java/com/google/cloud/dfmetrics/commands/MetricsFetcherCommand.java	10	2	0
public static TableReference getTableReference() in src/main/java/com/google/cloud/dfmetrics/output/BigqueryStore.java	10	2	1
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
private ListTimeSeriesRequest getTimeSeriesRequest() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/MonitoringClient.java	9	1	4
public static String sanitizeJobName() in src/main/java/com/google/cloud/dfmetrics/utils/MetricsCollectorUtils.java	9	1	1
public static String serializeToJson() in src/main/java/com/google/cloud/dfmetrics/utils/MetricsCollectorUtils.java	9	2	2
public static boolean validateMetricsFetcherConfig() in src/main/java/com/google/cloud/dfmetrics/utils/ConfigValidator.java	9	2	1
private Aggregation getAggregation() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/MonitoringClient.java	8	1	3
public TemplateConfig buildTemplateConfig() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/TemplateClient.java	8	1	1
public static Map castValuesToAppropriateTypes() in src/main/java/com/google/cloud/dfmetrics/utils/MetricsCollectorUtils.java	8	3	1
JobConfig createJobConfig() in src/main/java/com/google/cloud/dfmetrics/commands/MetricsFetcherCommand.java	8	1	1
public void printJobResponse() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/DataflowJobManager.java	7	1	0
private TimeInterval getJobTimeInterval() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/MetricsManager.java	7	1	0
private RuntimeEnvironment buildEnvironment() in src/main/java/com/google/cloud/dfmetrics/pipelinemanager/ClassicTemplateClient.java	7	1	1