apache / samza - 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 6,015 units with 49,508 lines of code in units (63.6% of code).

0 very complex units (0 lines of code)
2 complex units (280 lines of code)
53 medium complex units (3,202 lines of code)
231 simple units (6,647 lines of code)
5,729 very simple units (39,379 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
protected void perform() in samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaSqlFilterRemoteJoinRule.java	113	31	3
static StoreActions getStoreActions() in samza-core/src/main/java/org/apache/samza/storage/TransactionalStateTaskRestoreManager.java	167	28	12
def apply() in samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala	448	24	5
public boolean equals() in samza-api/src/main/java/org/apache/samza/system/OutgoingMessageEnvelope.java	40	22	1
private void validateJoinQuery() in samza-sql/src/main/java/org/apache/samza/sql/translator/JoinTranslator.java	69	22	3
public boolean handleCommand() in samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl/CliCommandHandler.java	64	21	1
def hasStopped() in samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala	95	20	0
private boolean isReady() in samza-core/src/main/java/org/apache/samza/container/RunLoop.java	19	18	0
def writeCheckpoint() in samza-core/src/main/scala/org/apache/samza/checkpoint/OffsetManager.scala	46	17	2
public static BiPredicate areSameFile() in samza-core/src/main/java/org/apache/samza/storage/blobstore/util/DirDiffUtil.java	78	17	2
def submitApplication() in samza-yarn/src/main/scala/org/apache/samza/job/yarn/ClientHelper.scala	111	17	5
def submitApplication() in samza-yarn3/src/main/scala/org/apache/samza/job/yarn/ClientHelper.scala	111	17	5
private static void setCompactionOptions() in samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv/RocksDbOptionsHelper.java	66	17	2
public boolean equals() in samza-api/src/main/java/org/apache/samza/system/IncomingMessageEnvelope.java	30	16	1
def toBytes() in samza-core/src/main/scala/org/apache/samza/serializers/SerdeManager.scala	45	16	2
private static String toString() in samza-core/src/main/java/org/apache/samza/util/ThreadUtil.java	63	16	1
private def readCheckpoints() in samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala	66	16	0
def restore() in samza-kv/src/main/scala/org/apache/samza/storage/kv/KeyValueStorageEngine.scala	72	15	1
void onResourceCompletedWithUnknownStatus() in samza-core/src/main/java/org/apache/samza/clustermanager/ContainerProcessManager.java	84	15	4
public static void main() in samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/Main.java	65	15	1
private Cluster openCluster() in samza-kv-couchbase/src/main/java/org/apache/samza/table/remote/couchbase/CouchbaseBucketRegistry.java	44	14	2
def fromBytes() in samza-core/src/main/scala/org/apache/samza/serializers/SerdeManager.scala	43	14	2
public boolean equals() in samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java	14	14	1
boolean checkStandbyConstraints() in samza-core/src/main/java/org/apache/samza/clustermanager/StandbyContainerManager.java	34	14	2
void open() in samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/CliShell.java	73	14	1
public Map toConfig() in samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv/descriptors/RocksDbTableDescriptor.java	45	14	1
public RelDataType getRelDataType() in samza-sql/src/main/java/org/apache/samza/sql/planner/RelSchemaConverter.java	34	14	1
static SqlTypeName toCalciteSqlType() in samza-sql/src/main/java/org/apache/samza/sql/planner/Checker.java	32	14	1
private SqlFieldSchema convertField() in samza-sql/src/main/java/org/apache/samza/sql/avro/AvroTypeFactoryImpl.java	37	14	3
public boolean equals() in samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java	25	13	1
public ReadWriteUpdateTable getTable() in samza-core/src/main/java/org/apache/samza/table/remote/RemoteTableProvider.java	65	13	0
OperatorImpl createOperatorImpl() in samza-core/src/main/java/org/apache/samza/operators/impl/OperatorImplGraph.java	39	13	3
private void commandSet() in samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl/CliCommandHandler.java	56	13	1
private List formatSchema4Display() in samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl/CliCommandHandler.java	92	13	1
function planToDagre() in samza-shell/src/main/visualizer/js/planToDagre.js	60	13	1
private boolean compareFieldTypes() in samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaSqlValidator.java	35	13	4
public static Object convertToJavaObject() in samza-sql/src/main/java/org/apache/samza/sql/avro/AvroRelConverter.java	48	13	2
def run[A]() in samza-core/src/main/scala/org/apache/samza/util/ExponentialSleepStrategy.scala	17	12	3
public void run() in samza-core/src/main/java/org/apache/samza/clustermanager/ClusterBasedJobCoordinator.java	75	12	0
private static DirDiff getDirDiff() in samza-core/src/main/java/org/apache/samza/storage/blobstore/util/DirDiffUtil.java	69	12	4
def buildOutgoingMessageEnvelope[T <: Checkpoint]() in samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala	39	12	2
private void setKinesisClientLibConfigs() in samza-aws/src/main/java/org/apache/samza/system/kinesis/KinesisConfig.java	37	12	2
private void validateJoinKeyType() in samza-sql/src/main/java/org/apache/samza/sql/translator/JoinTranslator.java	10	12	1
public void register() in samza-elasticsearch/src/main/java/org/apache/samza/system/elasticsearch/ElasticsearchSystemProducer.java	60	11	1
public void start() in samza-core/src/main/scala/org/apache/samza/storage/SideInputsManager.java	74	11	0
synchronized void update() in samza-core/src/main/java/org/apache/samza/operators/impl/WatermarkStates.java	34	11	2
private JobCoordinatorListener createJobCoordinatorListener() in samza-core/src/main/java/org/apache/samza/processor/StreamProcessor.java	79	11	0
private WorkerOp nextOp() in samza-core/src/main/java/org/apache/samza/container/RunLoop.java	21	11	0
List topologicalSort() in samza-core/src/main/java/org/apache/samza/execution/JobGraph.java	59	11	0
private void doOnProcessorChange() in samza-azure/src/main/java/org/apache/samza/coordinator/AzureJobCoordinator.java	57	11	1