apache / gobblin - 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 13,864 units with 122,074 lines of code in units (63.3% of code).

0 very complex units (0 lines of code)
8 complex units (838 lines of code)
136 medium complex units (8,123 lines of code)
645 simple units (19,565 lines of code)
13,075 very simple units (93,548 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 handlePrimitiveWritableComparable() in gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/orc/OrcUtils.java	90	35	2
public static String generateAvroToHiveColumnMapping() in gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/utils/AvroHiveTypeUtils.java	136	35	4
public Collection getCopyableFiles() in gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/replication/ConfigBasedDataset.java	116	29	2
public static String generateCreateTableDDL() in gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/query/HiveAvroORCQueryGenerator.java	132	29	16
public static String generateTableMappingDML() in gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/query/HiveAvroORCQueryGenerator.java	122	29	12
public boolean compare() in gobblin-data-management/src/main/java/org/apache/gobblin/util/schema_check/AvroSchemaCheckDefaultStrategy.java	80	29	2
private void runSynchronousModel() in gobblin-runtime/src/main/java/org/apache/gobblin/runtime/Task.java	105	28	0
Object convertField() in gobblin-core/src/main/java/org/apache/gobblin/converter/avro/JsonElementConversionWithAvroSchemaFactory.java	57	26	1
static boolean isEvolutionValid() in gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/orc/OrcUtils.java	64	25	2
public static WritableComparable createValueRecursively() in gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/orc/OrcUtils.java	59	23	2
private WorkUnit getWorkUnitForTopicPartition() in gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSource.java	107	23	5
public static Schema switchNamespace() in gobblin-utility/src/main/java/org/apache/gobblin/util/AvroUtils.java	65	23	2
static ObjectInspector createObjectInspector() in gobblin-hive-registration/src/main/java/org/apache/hadoop/hive/ql/io/orc/TypeDescriptionToObjectInspectorUtil.java	58	22	2
public void publishData() in gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/publisher/HiveConvertPublisher.java	83	22	1
public synchronized void put() in gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/DatabaseJobHistoryStoreV100.java	76	22	1
public void commit() in gobblin-runtime/src/main/java/org/apache/gobblin/runtime/Task.java	76	21	0
public void launchJob() in gobblin-runtime/src/main/java/org/apache/gobblin/runtime/AbstractJobLauncher.java	202	21	1
public List getWorkunits() in gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileBasedSource.java	92	21	1
void runInternal() in gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnAutoScalingManager.java	100	21	0
protected static DiffPathSet fullPathDiff() in gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/hive/HiveCopyEntityHelper.java	86	21	6
public String augmentBaseGetStatement() in gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/FlowSpecSearchObject.java	64	20	1
public Void call() in gobblin-runtime/src/main/java/org/apache/gobblin/runtime/SafeDatasetCommit.java	105	20	0
public void run() in gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactorJobRunner.java	76	20	0
static boolean isPriorFlowExecutionRunning() in gobblin-service/src/main/java/org/apache/gobblin/service/modules/utils/FlowCompilationValidationHelper.java	52	20	4
private ArrayList getNextRecordFromStream() in gobblin-core/src/main/java/org/apache/gobblin/source/extractor/utils/InputStreamCSVReader.java	72	19	0
private List flattenField() in gobblin-utility/src/main/java/org/apache/gobblin/util/AvroFlattener.java	75	19	5
public static TypeDescription getOrcSchema() in gobblin-utility/src/main/java/org/apache/gobblin/util/orc/AvroOrcSchemaConverter.java	55	19	1
public static JsonElementConverter getConvertor() in gobblin-core/src/main/java/org/apache/gobblin/converter/avro/JsonElementConversionFactory.java	46	18	3
protected void handleContainerCompletion() in gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnService.java	63	18	1
public FutureCallbackHolder() in gobblin-modules/gobblin-elasticsearch/src/main/java/org/apache/gobblin/elasticsearch/writer/FutureCallbackHolder.java	110	18	3
private boolean verifyInput() in gobblin-iceberg/src/main/java/org/apache/gobblin/iceberg/GobblinMCEProducer.java	39	18	4
private JobExecutionInfo processQueryById() in gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/DatabaseJobHistoryStoreV100.java	97	18	4
public static boolean isDagFinished() in gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/proc/DagProcUtils.java	36	17	1
protected void processMessage() in gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/KafkaJobStatusMonitor.java	70	17	1
public synchronized boolean requestTargetNumberOfContainers() in gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnService.java	81	17	2
public Iterable convertRecord() in gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/AbstractAvroToOrcConverter.java	245	17	3
private Converter buildConverter() in gobblin-modules/gobblin-orc/src/main/java/org/apache/gobblin/writer/GenericRecordToOrcValueWriter.java	36	17	2
private Schema flatten() in gobblin-utility/src/main/java/org/apache/gobblin/util/AvroFlattener.java	63	17	3
private void addPropertiesToTasks() in gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/DatabaseJobHistoryStoreV101.java	56	17	4
public void extractMetadata() in gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/restapi/RestApiExtractor.java	53	16	3
static Map getPreviousWatermarksForAllTables() in gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/QueryBasedSource.java	64	16	1
public AddSpecResponse onAddSpec() in gobblin-service/src/main/java/org/apache/gobblin/service/modules/scheduler/GobblinServiceJobScheduler.java	62	16	1
private LeaseAttemptStatus doTryAcquireLease() in gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/MysqlMultiActiveLeaseArbiter.java	83	16	2
public CopyableFile build() in gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/CopyableFile.java	41	16	0
public boolean equals() in gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/replication/HadoopFsReplicaConfig.java	30	16	1
public D readRecordImpl() in gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaExtractor.java	55	16	1
private Schema parseSchemaFromPrimitive() in gobblin-iceberg/src/main/java/org/apache/gobblin/iceberg/Utils/TypeInfoToSchemaParser.java	58	16	1
protected void run() in gobblin-runtime/src/main/java/org/apache/gobblin/runtime/StreamModelTaskRunner.java	71	15	0
private void submitCompactionJobsAndWaitForCompletion() in gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactor.java	42	15	0
List getNextEdges() in gobblin-service/src/main/java/org/apache/gobblin/service/modules/flowgraph/pathfinder/AbstractPathFinder.java	69	15	4