GoogleCloudPlatform / DataflowTemplates

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 7,089 units with 82,752 lines of code in units (51.1% of code).

6 very complex units (1,371 lines of code)
25 complex units (2,485 lines of code)
142 medium complex units (9,072 lines of code)
336 simple units (13,184 lines of code)
6,580 very simple units (56,640 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 GenericRecord convert() in v1/src/main/java/com/google/cloud/teleport/spanner/SpannerRecordConverter.java	242	100	1
public Mutation apply() in v1/src/main/java/com/google/cloud/teleport/spanner/AvroRecordConverter.java	181	62	1
public void processParamType() in plugins/core-plugin/src/main/java/com/google/cloud/teleport/plugin/model/ImageSpecParameter.java	474	57	1
public static Code parseSpannerDataType() in v1/src/main/java/com/google/cloud/teleport/spanner/TextImportTransform.java	62	53	2
public Collection convert() in v1/src/main/java/com/google/cloud/teleport/spanner/DdlToAvroSchemaConverter.java	258	52	1
protected final Mutation parseRow() in v1/src/main/java/com/google/cloud/teleport/spanner/CSVRecordToMutation.java	154	51	4
public static SizedType parseSpannerType() in v1/src/main/java/com/google/cloud/teleport/spanner/common/SizedType.java	171	50	2
public PCollectionTuple expand() in v1/src/main/java/com/google/cloud/teleport/spanner/ImportTransform.java	231	45	1
public static String typeString() in v1/src/main/java/com/google/cloud/teleport/spanner/common/SizedType.java	93	39	3
public ImageSpec buildSpecModel() in plugins/core-plugin/src/main/java/com/google/cloud/teleport/plugin/model/TemplateDefinitions.java	178	37	1
private Schema avroType() in v1/src/main/java/com/google/cloud/teleport/spanner/DdlToAvroSchemaConverter.java	66	34	2
public StandardSQLTypeName convertOracleToBigQueryColumnType() in v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/utils/DataStreamClient.java	51	33	1
public static SpannerMigrationException parse() in v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/exceptions/SpannerExceptionParser.java	79	33	1
private static SizedType parseSpannerType() in v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/Column.java	103	31	2
public static List getRegexes() in metadata/src/main/java/com/google/cloud/teleport/metadata/util/MetadataUtils.java	120	31	1
public Table toTable() in v1/src/main/java/com/google/cloud/teleport/spanner/AvroSchemaToDdlConverter.java	122	31	2
public StandardSQLTypeName convertMysqlToBigQueryColumnType() in v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/utils/DataStreamClient.java	51	30	1
private static String getColumnValueByType() in v2/gcs-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/processing/dml/DMLGenerator.java	52	30	4
public static Schema toBeamSchema() in v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/utils/BeamUtils.java	107	30	3
private static String getColumnValueByType() in v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/dml/MySQLDMLGenerator.java	52	30	4
private static PreparedStatementValueObject parseAndCastToCassandraType() in v2/spanner-to-sourcedb/src/main/java/com/google/cloud/teleport/v2/templates/dbutils/dml/CassandraTypeHandler.java	97	30	2
public void processElement() in v1/src/main/java/com/google/cloud/teleport/spanner/SplitIntoRangesFn.java	144	30	1
public StandardSQLTypeName convertPostgresqlToBigQueryColumnType() in v2/datastream-common/src/main/java/com/google/cloud/teleport/v2/datastream/utils/DataStreamClient.java	50	29	1
private static String typeString() in v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/ddl/Column.java	62	29	2
static Object fromBeamType() in v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/utils/DataCastingUtils.java	113	29	3
public static List sourceTextToTargetObjects() in v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/utils/DataCastingUtils.java	104	28	4
static SpannerOptions buildSpannerOptions() in v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerAccessor.java	126	27	1
private static Object getColumnValueFromResultSet() in v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/spannerchangestreamstobigquery/schemautils/SpannerToBigQueryUtils.java	70	26	2
static PipelineResult run() in v2/jdbc-and-googlecloud/src/main/java/com/google/cloud/teleport/v2/templates/JdbcToBigQuery.java	123	26	2
private static long estimateArrayValue() in v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/MutationSizeEstimator.java	69	26	1
public boolean equals() in v1/src/main/java/com/google/cloud/teleport/spanner/ddl/Ddl.java	51	26	1
private static Object convertRequiredField() in v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/utils/BigQueryAvroUtils.java	103	25	4
protected String stageFlexTemplate() in plugins/templates-maven-plugin/src/main/java/com/google/cloud/teleport/plugin/maven/TemplatesStageMojo.java	143	25	3
public static String getTargetSql() in v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/utils/ModelUtils.java	92	24	6
public void setUpBase() in it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/TemplateTestBase.java	110	24	0
private FieldType toBeamRowType() in v1/src/main/java/com/google/cloud/teleport/bigtable/CassandraRowMapperFn.java	49	24	1
static String handleLogicalFieldType() in v2/spanner-common/src/main/java/com/google/cloud/teleport/v2/spanner/migrations/avro/GenericRecordTypeConvertor.java	83	23	4
private static StandardSQLTypeName mapCassandraToBigQueryType() in v2/astradb-to-bigquery/src/main/java/com/google/cloud/teleport/v2/astradb/transforms/AstraDbToBigQueryMappingFn.java	41	23	1
public static String propertyType() in v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/database/CypherPatterns.java	51	23	1
protected LaunchInfo launchTemplate() in it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/TemplateTestBase.java	69	23	3
private void listIndexColumns() in v1/src/main/java/com/google/cloud/teleport/spanner/ddl/InformationSchemaScanner.java	67	23	2
public WriteFilesResult expand() in v1/src/main/java/com/google/cloud/teleport/spanner/ExportTransform.java	457	23	1
public PCollectionTuple expand() in v1/src/main/java/com/google/cloud/teleport/templates/common/DatadogConverters.java	93	23	1
public String cleanDataTypeValueSql() in v2/datastream-to-sql/src/main/java/com/google/cloud/teleport/v2/utils/DatastreamToPostgresDML.java	36	22	3
public PDone expand() in v2/elasticsearch-common/src/main/java/com/google/cloud/teleport/v2/elasticsearch/transforms/WriteToElasticsearch.java	111	22	1
private static Set getRelationshipSchemaStatements() in v2/googlecloud-to-neo4j/src/main/java/com/google/cloud/teleport/v2/neo4j/database/CypherGenerator.java	133	22	2
public static Statement generateShadowTableReadSQL() in v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/ShadowTableReadUtils.java	67	22	4
public static WriteResult processKafkaRecords() in v2/kafka-to-bigquery/src/main/java/com/google/cloud/teleport/v2/templates/KafkaToBigQueryFlex.java	45	22	2
private static void setBeamValueToMutation() in v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/MutationUtils.java	98	22	4
public static Struct beamRowToStruct() in v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/StructUtils.java	95	22	1