apache / spark-kubernetes-operator - 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 331 units with 3,869 lines of code in units (53.1% of code).

0 very complex units (0 lines of code)
1 complex units (80 lines of code)
9 medium complex units (530 lines of code)
20 simple units (590 lines of code)
301 very simple units (2,669 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 resolve_jira_issue() in dev/merge_spark_pr.py	80	26	3
def main() in dev/merge_spark_pr.py	94	21	0
public static Object resolveValueToPrimitiveType() in spark-operator/src/main/java/org/apache/spark/k8s/operator/config/ConfigOption.java	24	15	2
def choose_jira_assignee() in dev/merge_spark_pr.py	49	14	1
protected Optional observeDriverTermination() in spark-operator/src/main/java/org/apache/spark/k8s/operator/reconciler/observers/BaseAppDriverObserver.java	60	13	3
public ApplicationStatus terminateOrRestart() in spark-operator-api/src/main/java/org/apache/spark/k8s/operator/status/ApplicationStatus.java	66	13	4
def standardize_jira_ref() in dev/merge_spark_pr.py	19	12	1
public ReconcileProgress reconcile() in spark-operator/src/main/java/org/apache/spark/k8s/operator/reconciler/reconcilesteps/AppInitStep.java	75	11	2
public ReconcileProgress reconcile() in spark-operator/src/main/java/org/apache/spark/k8s/operator/reconciler/reconcilesteps/AppCleanUpStep.java	81	11	2
def merge_pr() in dev/merge_spark_pr.py	62	11	5
public ReconcileProgress reconcile() in spark-operator/src/main/java/org/apache/spark/k8s/operator/reconciler/reconcilesteps/AppRunningStep.java	49	10	2
public static Optional getOrCreateSecondaryResource() in spark-operator/src/main/java/org/apache/spark/k8s/operator/utils/ReconcilerUtils.java	37	9	2
def initialize_jira() in dev/merge_spark_pr.py	28	9	0
private static void deleteLocalFileFromPathKey() in spark-operator/src/main/java/org/apache/spark/k8s/operator/reconciler/SparkAppResourceSpecFactory.java	19	8	2
public T decorate() in spark-operator/src/main/java/org/apache/spark/k8s/operator/decorators/DriverResourceDecorator.java	24	8	1
public boolean isHealthy() in spark-operator/src/main/java/org/apache/spark/k8s/operator/probe/HealthProbe.java	20	8	0
protected SparkAppDriverConf buildDriverConf() in spark-submission-worker/src/main/java/org/apache/spark/k8s/operator/SparkAppSubmissionWorker.java	40	8	2
public static boolean isPodReady() in spark-operator/src/main/java/org/apache/spark/k8s/operator/utils/PodUtils.java	16	7	1
public ReconcileProgress reconcile() in spark-operator/src/main/java/org/apache/spark/k8s/operator/reconciler/reconcilesteps/ClusterInitStep.java	55	7	2
private boolean checkInformersHealth() in spark-operator/src/main/java/org/apache/spark/k8s/operator/probe/HealthProbe.java	29	7	1
def get_jira_issue() in dev/merge_spark_pr.py	21	7	2
public void generate() in build-tools/docs-utils/src/main/java/org/apache/spark/k8s/operator/utils/ConfOptionDocGenerator.java	33	6	1
private void updateSpecAndScheduleHealthCheck() in spark-operator/src/main/java/org/apache/spark/k8s/operator/metrics/healthcheck/SentinelManager.java	33	6	3
public T timeControllerExecution() in spark-operator/src/main/java/org/apache/spark/k8s/operator/metrics/source/OperatorJosdkMetrics.java	54	6	1
public static PodPhase getPhase() in spark-operator/src/main/java/org/apache/spark/k8s/operator/utils/PodPhase.java	14	6	1
public static boolean isDriverPodStarted() in spark-operator/src/main/java/org/apache/spark/k8s/operator/utils/PodUtils.java	14	6	2
public Optional observe() in spark-operator/src/main/java/org/apache/spark/k8s/operator/reconciler/observers/AppDriverTimeoutObserver.java	33	6	3
private T resolveValue() in spark-operator/src/main/java/org/apache/spark/k8s/operator/config/ConfigOption.java	24	6	0
protected boolean updateWatchingNamespaces() in spark-operator/src/main/java/org/apache/spark/k8s/operator/SparkOperator.java	25	6	1
def get_json() in dev/merge_spark_pr.py	22	6	1
public void checkHealth() in spark-operator/src/main/java/org/apache/spark/k8s/operator/metrics/healthcheck/SentinelManager.java	24	5	2
private void patchAndStatusWithVersionLocked() in spark-operator/src/main/java/org/apache/spark/k8s/operator/utils/StatusRecorder.java	32	5	2
public static boolean isConflictForExistingResource() in spark-operator/src/main/java/org/apache/spark/k8s/operator/utils/SparkExceptionUtils.java	7	5	1
public void set() in spark-operator/src/main/java/org/apache/spark/k8s/operator/utils/LoggingUtils.java	14	5	1
protected List getReconcileSteps() in spark-operator/src/main/java/org/apache/spark/k8s/operator/reconciler/SparkAppReconciler.java	37	5	1
private static Optional getLocalFileFromPathKey() in spark-operator/src/main/java/org/apache/spark/k8s/operator/reconciler/SparkAppResourceSpecFactory.java	10	5	2
private static Map getOrCreateLocalFileForDriverSpec() in spark-operator/src/main/java/org/apache/spark/k8s/operator/reconciler/SparkAppResourceSpecFactory.java	15	5	2
private static Map getOrCreateLocalFileForExecutorSpec() in spark-operator/src/main/java/org/apache/spark/k8s/operator/reconciler/SparkAppResourceSpecFactory.java	15	5	2
private static Ingress buildIngress() in spark-submission-worker/src/main/java/org/apache/spark/k8s/operator/utils/DriverServiceIngressUtils.java	28	5	2
public SparkClusterResourceSpec getResourceSpec() in spark-submission-worker/src/main/java/org/apache/spark/k8s/operator/SparkClusterSubmissionWorker.java	17	5	2
public static boolean attemptRestartOnState() in spark-operator-api/src/main/java/org/apache/spark/k8s/operator/spec/RestartPolicy.java	9	5	2
public static Map parseSinkProperties() in spark-operator/src/main/java/org/apache/spark/k8s/operator/metrics/MetricsSystemFactory.java	25	4	1
private static void sinkPropertiesSanityCheck() in spark-operator/src/main/java/org/apache/spark/k8s/operator/metrics/MetricsSystemFactory.java	17	4	1
private static boolean shouldSentinelWatchGivenNamespace() in spark-operator/src/main/java/org/apache/spark/k8s/operator/metrics/healthcheck/SentinelManager.java	10	4	1
public boolean handleSentinelResourceReconciliation() in spark-operator/src/main/java/org/apache/spark/k8s/operator/metrics/healthcheck/SentinelManager.java	21	4	2
public void receivedEvent() in spark-operator/src/main/java/org/apache/spark/k8s/operator/metrics/source/OperatorJosdkMetrics.java	20	4	2
public static void deleteResourceIfExists() in spark-operator/src/main/java/org/apache/spark/k8s/operator/utils/ReconcilerUtils.java	20	4	3
public static Optional areOperatorsStarted() in spark-operator/src/main/java/org/apache/spark/k8s/operator/utils/ProbeUtil.java	16	4	1
public UpdateControl reconcile() in spark-operator/src/main/java/org/apache/spark/k8s/operator/reconciler/SparkAppReconciler.java	25	4	2
public DeleteControl cleanup() in spark-operator/src/main/java/org/apache/spark/k8s/operator/reconciler/SparkAppReconciler.java	29	4	2