mozilla / gcp-ingestion - Conditional 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 719 units with 5,999 lines of code in units (51.2% of code).

1 very complex units (113 lines of code)
0 complex units (0 lines of code)
12 medium complex units (582 lines of code)
39 simple units (1,082 lines of code)
667 very simple units (4,222 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 scrub() in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder/MessageScrubber.java	113	51	2
private void processField() in ingestion-core/src/main/java/com/mozilla/telemetry/ingestion/core/transform/PubsubMessageToObjectNode.java	73	24	5
public ObjectNode toJson() in ingestion-beam/src/main/java/com/mozilla/telemetry/amplitude/AmplitudeEvent.java	53	22	0
public PubsubMessage apply() in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder/ParseUserAgent.java	48	19	1
public void processElement() in ingestion-beam/src/main/java/com/mozilla/telemetry/contextualservices/FilterByDocType.java	53	19	2
private Optional coerceSingleValueToBqType() in ingestion-core/src/main/java/com/mozilla/telemetry/ingestion/core/transform/PubsubMessageToObjectNode.java	43	19	2
public void processElement() in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder/ParsePayload.java	106	17	2
public PCollection expand() in ingestion-beam/src/main/java/com/mozilla/telemetry/io/Read.java	65	15	1
public Symbol doAction() in ingestion-beam/src/main/java/com/mozilla/telemetry/avro/GuidedJsonDecoder.java	56	12	2
public static String normalizeOs() in ingestion-beam/src/main/java/com/mozilla/telemetry/transforms/NormalizeAttributes.java	16	11	1
def _unschedulable_due_to_pvc() in ingestion-edge/ingestion_edge/flush_manager.py	15	11	1
Output getOutput() in ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/config/SinkConfig.java	30	11	3
static OutputType get() in ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/config/SinkConfig.java	24	11	1
public PubsubMessage apply() in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder/GeoCityLookup.java	54	10	1
public PCollection expand() in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder/ipprivacy/HashClientInfo.java	35	10	1
public TableDestination getTableDestination() in ingestion-beam/src/main/java/com/mozilla/telemetry/transforms/KeyByBigQueryTableDestination.java	53	10	1
private static void jsonMove() in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder/ParsePayload.java	24	9	4
List readAllowedEventsFromFile() in ingestion-beam/src/main/java/com/mozilla/telemetry/amplitude/ParseAmplitudeEvents.java	31	9	0
private static String extractSource() in ingestion-beam/src/main/java/com/mozilla/telemetry/contextualservices/ParseReportingUrl.java	14	9	1
private static String extractInteractionType() in ingestion-beam/src/main/java/com/mozilla/telemetry/contextualservices/ParseReportingUrl.java	12	9	1
Output getOutput() in ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/config/SinkConfig.java	57	9	3
public static Input getInput() in ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/config/SinkConfig.java	43	9	1
protected CompletableFuture close() in ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/io/BigQuery.java	31	9	0
private static PubsubMessage apply() in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder/ParseUri.java	37	8	1
private void loadAllSchemas() in ingestion-core/src/main/java/com/mozilla/telemetry/ingestion/core/schema/SchemaStore.java	35	8	0
def publish() in ingestion-edge/ingestion_edge/util.py	17	8	2
def delete_complete_jobs() in ingestion-edge/ingestion_edge/flush_manager.py	54	8	3
private static void sanitizeMobileSearchKeys() in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder/MessageScrubber.java	28	7	1
private static PubsubMessage applyFailures() in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder/ParseUri.java	26	7	1
private void addAttributesFromPayload() in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder/ParsePayload.java	46	7	3
private void deprecationCheck() in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder/ParsePayload.java	19	7	2
public PubsubMessage apply() in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder/ExtractIpFromLogEntry.java	36	7	1
private List readPairsFromFile() in ingestion-beam/src/main/java/com/mozilla/telemetry/contextualservices/ParseReportingUrl.java	25	7	2
void transformForBqSchema() in ingestion-core/src/main/java/com/mozilla/telemetry/ingestion/core/transform/PubsubMessageToObjectNode.java	26	7	3
private static boolean isMapType() in ingestion-core/src/main/java/com/mozilla/telemetry/ingestion/core/transform/PubsubMessageToObjectNode.java	8	7	1
def Pull() in ingestion-edge/pubsub_emulator.py	21	7	3
def init_app() in ingestion-edge/ingestion_edge/publish.py	24	7	1
static boolean bug1602844Affected() in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder/MessageScrubber.java	8	6	1
public void processElement() in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder/ParseProxy.java	30	6	2
public PubsubMessage apply() in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder/GeoIspLookup.java	33	6	1
static List extractEvents() in ingestion-beam/src/main/java/com/mozilla/telemetry/amplitude/ParseAmplitudeEvents.java	23	6	3
static boolean isEventAllowed() in ingestion-beam/src/main/java/com/mozilla/telemetry/amplitude/ParseAmplitudeEvents.java	7	6	4
static void validateSinkOptions() in ingestion-beam/src/main/java/com/mozilla/telemetry/options/SinkOptions.java	15	6	1
public PCollection expand() in ingestion-beam/src/main/java/com/mozilla/telemetry/contextualservices/EmitCounters.java	26	6	1
private static String getOsParam() in ingestion-beam/src/main/java/com/mozilla/telemetry/contextualservices/ParseReportingUrl.java	16	6	1
public static PipelineResult run() in ingestion-beam/src/main/java/com/mozilla/telemetry/Republisher.java	37	6	1
private static boolean isNestedListType() in ingestion-core/src/main/java/com/mozilla/telemetry/ingestion/core/transform/PubsubMessageToObjectNode.java	7	6	2
private TextNode compactHistogramEncoding() in ingestion-core/src/main/java/com/mozilla/telemetry/ingestion/core/transform/PubsubMessageToObjectNode.java	22	6	2
public static Duration parseJavaDuration() in ingestion-core/src/main/java/com/mozilla/telemetry/ingestion/core/util/Time.java	31	6	1
public Schema getSchema() in ingestion-core/src/main/java/com/mozilla/telemetry/ingestion/core/schema/BigQuerySchemaStore.java	25	6	2