GoogleCloudPlatform / dataproc-templates

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 601 units with 9,114 lines of code in units (40.9% of code).

0 very complex units (0 lines of code)
0 complex units (0 lines of code)
5 medium complex units (218 lines of code)
44 simple units (1,857 lines of code)
552 very simple units (7,039 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
def run() in python/dataproc_templates/jdbc/jdbc_to_gcs.py	63	15	4
public Option getJDBCType() in java/src/main/java/com/google/cloud/dataproc/dialects/SpannerPostgresJDBCDialect.java	30	13	1
public Option getJDBCType() in java/src/main/java/com/google/cloud/dataproc/dialects/SpannerJdbcDialect.java	30	13	1
def run() in python/dataproc_templates/jdbc/jdbc_to_jdbc.py	66	13	4
public void validateInput() in java/src/main/java/com/google/cloud/dataproc/templates/jdbc/JDBCToBigQuery.java	29	11	0
public static void writeToGCS() in java/src/main/java/com/google/cloud/dataproc/templates/pubsub/PubSubToGCS.java	44	10	5
public void validateInput() in java/src/main/java/com/google/cloud/dataproc/templates/kafka/KafkaToBQDstream.java	57	9	0
public void validateInput() in java/src/main/java/com/google/cloud/dataproc/templates/kafka/KafkaToGCSDstream.java	59	9	0
public void validateInput() in java/src/main/java/com/google/cloud/dataproc/templates/gcs/TextToBigquery.java	48	9	0
public void validateInput() in java/src/main/java/com/google/cloud/dataproc/templates/s3/S3ToBigQuery.java	45	9	0
def run() in python/dataproc_templates/elasticsearch/elasticsearch_to_bq.py	37	9	4
def run() in python/dataproc_templates/jdbc/jdbc_to_bigquery.py	50	9	4
def parse_args() in python/dataproc_templates/snowflake/snowflake_to_gcs.py	126	9	1
public void validateInput() in java/src/main/java/com/google/cloud/dataproc/templates/dataplex/DataplexGCStoBQ.java	16	8	0
public void validateInput() in java/src/main/java/com/google/cloud/dataproc/templates/kafka/KafkaToBQ.java	49	8	0
private boolean isPartitionsPropertyValid() in java/src/main/java/com/google/cloud/dataproc/templates/jdbc/JDBCToSpannerConfig.java	10	8	0
def run() in python/dataproc_templates/azure/azure_blob_storage_to_bigquery.py	42	8	4
def _filter_table_list() in notebooks/util/jdbc/jdbc_input_manager_interface.py	12	8	3
public void validateInput() in java/src/main/java/com/google/cloud/dataproc/templates/pubsublite/PubSubLiteToBigTable.java	47	7	0
public List buildSparkSchemaFromDataplexSchema() in java/src/main/java/com/google/cloud/dataproc/templates/util/Dataplex/DataplexEntityUtil.java	46	7	3
private boolean isInputValid() in java/src/main/java/com/google/cloud/dataproc/templates/databases/MongoToBQConfig.java	9	7	0
public void validateInput() in java/src/main/java/com/google/cloud/dataproc/templates/jdbc/JDBCToSpanner.java	21	7	0
public void validateInput() in java/src/main/java/com/google/cloud/dataproc/templates/gcs/GCStoBigquery.java	38	7	0
public void validateInput() in java/src/main/java/com/google/cloud/dataproc/templates/gcs/GCStoGCS.java	38	7	0
def parse_args() in python/dataproc_templates/elasticsearch/elasticsearch_to_bigtable.py	92	7	1
def parse_args() in python/dataproc_templates/elasticsearch/elasticsearch_to_bq.py	90	7	1
def parse_args() in python/dataproc_templates/elasticsearch/elasticsearch_to_gcs.py	96	7	1
def parse_args() in python/dataproc_templates/cassandra/cassandra_to_bigquery.py	75	7	1
def parse_args() in python/dataproc_templates/cassandra/cassandra_to_gcs.py	82	7	1
def run() in python/dataproc_templates/s3/s3_to_bigquery.py	45	7	4
def read_partitioning_df() in notebooks/util/jdbc/jdbc_input_manager_interface.py	27	7	2
public void validateInput() in java/src/main/java/com/google/cloud/dataproc/templates/pubsub/PubSubToBigTable.java	45	6	0
public void validateInput() in java/src/main/java/com/google/cloud/dataproc/templates/pubsub/PubSubToBQ.java	48	6	0
public void runTemplate() in java/src/main/java/com/google/cloud/dataproc/templates/dataplex/DataplexGCStoBQ.java	42	6	0
public void runTemplate() in java/src/main/java/com/google/cloud/dataproc/templates/bigquery/BigQueryToGCS.java	30	6	0
public boolean isValid() in java/src/main/java/com/google/cloud/dataproc/templates/config/GeneralTemplateConfig.java	33	6	2
public void validateInput() in java/src/main/java/com/google/cloud/dataproc/templates/kafka/KafkaToPubSub.java	42	6	0
public void validateInput() in java/src/main/java/com/google/cloud/dataproc/templates/kafka/KafkaToGCS.java	45	6	0
private boolean isInputValid() in java/src/main/java/com/google/cloud/dataproc/templates/databases/CassandraToGCSConfig.java	8	6	0
public void validateInput() in java/src/main/java/com/google/cloud/dataproc/templates/databases/MongoToGCS.java	19	6	0
private boolean isInputValid() in java/src/main/java/com/google/cloud/dataproc/templates/databases/CassandraToBqConfig.java	8	6	0
public void runTemplate() in java/src/main/java/com/google/cloud/dataproc/templates/databases/SpannerToGCS.java	36	6	0
public void runTemplate() in java/src/main/java/com/google/cloud/dataproc/templates/jdbc/JDBCToBigQuery.java	33	6	0
public void runTemplate() in java/src/main/java/com/google/cloud/dataproc/templates/gcs/GCStoBigquery.java	38	6	0
private boolean isInputValid() in java/src/main/java/com/google/cloud/dataproc/templates/gcs/GCStoBigTableConfig.java	8	6	0
public void validateInput() in java/src/main/java/com/google/cloud/dataproc/templates/gcs/GCStoMongo.java	36	6	0
def run() in python/dataproc_templates/elasticsearch/elasticsearch_to_bigtable.py	38	6	4
def run() in python/dataproc_templates/elasticsearch/elasticsearch_to_gcs.py	30	6	4
def add_spark_options() in python/dataproc_templates/util/argument_parsing.py	17	6	3
public void validateInput() in java/src/main/java/com/google/cloud/dataproc/templates/pubsub/PubSubToGCS.java	44	5	0