netflix / mantis - 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,311 units with 53,894 lines of code in units (67.2% of code).

0 very complex units (0 lines of code)
6 complex units (974 lines of code)
55 medium complex units (3,032 lines of code)
242 simple units (7,355 lines of code)
6,008 very simple units (42,533 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
JobDefinition getResolvedJobDefinition() in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobDefinitionResolver.java	91	45	3
public RxServer createServer() in mantis-network/src/main/java/io/reactivex/mantis/network/push/PushServerSse.java	184	43	0
public Observable handle() in mantis-runtime/src/main/java/io/mantisrx/runtime/sink/ServerSentEventRequestHandler.java	196	42	2
protected Observable manageConnectionWithCompression() in mantis-network/src/main/java/io/reactivex/mantis/network/push/PushServer.java	174	34	22
private Route getJobClusterRoutes() in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobClusterRoute.java	285	29	0
public boolean equals() in mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/clutch/ClutchConfiguration.java	44	26	1
public void configureNewPipeline() in mantis-network/src/main/java/io/reactivex/mantis/network/push/LegacyTcpPipelineConfigurator.java	111	25	1
public boolean equals() in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/MantisWorkerMetadataImpl.java	25	23	1
public void onKillJobResponse() in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java	60	21	1
private Observable createBackPressuredConsumerObs() in mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/KafkaSource.java	125	21	2
public boolean equals() in mantis-common/src/main/java/io/mantisrx/runtime/descriptor/StageSchedulingInfo.java	39	21	1
public void start() in mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/JobAutoScaler.java	139	21	0
public void processEvent() in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/JobActor.java	92	20	2
private boolean workerFilter() in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/MantisJobMetadataView.java	40	19	4
public void configureNewPipeline() in mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/BatchedRxEventPipelineConfigurator.java	85	18	1
public void onJobClusterInitialize() in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java	115	16	1
protected Observable streamContent() in mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client/SseWorkerConnection.java	60	16	4
public void executeStage() in mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/WorkerExecutionOperationsNetworkStage.java	186	15	1
private Pair validateSubmitJobRequest() in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobsRoute.java	105	15	2
public boolean equals() in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/MantisJobClusterMetadataView.java	17	15	1
public GetClusterUsageResponse getClusterUsage() in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ExecutorStateManagerImpl.java	59	15	1
public RxServer createServer() in mantis-network/src/main/java/io/reactivex/mantis/network/push/LegacyTcpPushServer.java	95	15	0
protected static List parseTargetInfo() in mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/source/JobSource.java	57	15	1
public Subscriber call() in mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/WorkerMetricHandler.java	140	15	1
public void checkHeartBeats() in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/JobActor.java	81	14	1
private Observable getFilteredTerminalJobList() in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java	34	14	2
private MantisJobBuilder makeMantisJob() in mantis-runtime/src/main/java/io/mantisrx/runtime/core/MantisStreamImpl.java	49	14	3
static List tokenize() in mantis-common/src/main/java/io/mantisrx/common/compression/CompressionUtils.java	50	14	2
private void validateSchedulingInfo() in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobDefinition.java	30	13	1
private Route getJobRoutes() in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobRoute.java	153	13	0
private void initializeRunningWorkers() in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/JobActor.java	57	13	0
public boolean equals() in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java	19	13	1
private void startScalerService() in mantis-jm-akka/src/main/java/io/mantisrx/server/worker/jobmaster/akka/rules/ScalerControllerActor.java	91	13	1
public boolean equals() in mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/WorkerHost.java	27	13	1
private void validateSchedulingInfo() in mantis-common/src/main/java/io/mantisrx/runtime/MantisJobDefinition.java	30	13	1
public boolean equals() in mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameter.java	25	13	1
public void start() in mantis-common/src/main/java/io/mantisrx/common/metrics/MetricsServer.java	61	13	0
public Metrics() in mantis-common/src/main/java/io/mantisrx/common/metrics/Metrics.java	27	13	1
public boolean equals() in mantis-common/src/main/java/io/mantisrx/common/network/ServerSlotManager.java	26	13	1
public boolean equals() in mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/control/AdaptiveAutoscalerConfig.java	17	13	1
public boolean equals() in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobDefinition.java	14	12	1
public boolean equals() in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobClusterDefinitionImpl.java	14	12	1
private Pair validateSubmitJobRequest() in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobClusterRoute.java	53	12	1
public static Optional getLastSubmittedJobId() in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobListHelper.java	31	12	2
public boolean equals() in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/MantisStageMetadataImpl.java	11	12	1
public void route() in mantis-network/src/main/java/io/reactivex/mantis/network/push/RoundRobinRouter.java	31	12	2
public Event process() in mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/EventProcessor.java	46	12	2
public boolean equals() in mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/SourceJobParameters.java	14	12	1
public static Map checkThenCreateState() in mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/ParameterUtils.java	41	12	2
public void call() in mantis-common/src/main/java/io/reactivx/mantis/operators/OnSubscribeRedo.java	115	12	1