public void open()

in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraCommitter.java [104:110]

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

    public void open() throws Exception {
        if (builder == null) {
            throw new RuntimeException("No ClusterBuilder was set.");
        }
        cluster = builder.getCluster();
        session = cluster.connect();
    }