public void onRemove()

in flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/FlinkDeploymentMetrics.java [164:189]

• 25 lines of code
• 7 McCabe index (conditional complexity)

    public void onRemove(FlinkDeployment flinkApp) {
        var namespace = flinkApp.getMetadata().getNamespace();
        var name = flinkApp.getMetadata().getName();

        if (deploymentStatuses.containsKey(namespace)) {
            deploymentStatuses.get(namespace).values().forEach(names -> names.remove(name));
        }
        if (deploymentFlinkVersions.containsKey(namespace)) {
            deploymentFlinkVersions.get(namespace).values().forEach(names -> names.remove(name));
        }
        if (deploymentFlinkMinorVersions.containsKey(namespace)) {
            deploymentFlinkMinorVersions
                    .get(namespace)
                    .values()
                    .forEach(names -> names.remove(name));
        }
        if (deploymentCpuUsage.containsKey(namespace)) {
            deploymentCpuUsage.get(namespace).remove(name);
        }
        if (deploymentMemoryUsage.containsKey(namespace)) {
            deploymentMemoryUsage.get(namespace).remove(name);
        }
        if (deploymentStateSize.containsKey(namespace)) {
            deploymentStateSize.get(namespace).remove(name);
        }
    }