public static void shutdown()

in spark-job/src/main/java/org/apache/cassandra/diff/Differ.java [338:363]

• 26 lines of code
• 5 McCabe index (conditional complexity)

    public static void shutdown()
    {
        try
        {
            if (srcDiffCluster != null) {
                srcDiffCluster.stop();
                srcDiffCluster.close();
                srcDiffCluster = null;
            }
            if (targetDiffCluster != null) {
                targetDiffCluster.stop();
                targetDiffCluster.close();
                targetDiffCluster = null;
            }
            if (journalSession != null) {
                journalSession.close();
                journalSession.getCluster().close();
                journalSession = null;
            }
            COMPARISON_EXECUTOR.shutdown();
        }
        catch (Exception e)
        {
            throw new RuntimeException(e);
        }
    }