public void open()

in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraTupleWriteAheadSink.java [74:85]

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

    public void open() throws Exception {
        super.open();
        if (!getRuntimeContext().isCheckpointingEnabled()) {
            throw new IllegalStateException(
                    "The write-ahead log requires checkpointing to be enabled.");
        }
        cluster = builder.getCluster();
        session = cluster.connect();
        preparedStatement = session.prepare(insertQuery);

        fields = new Object[((TupleSerializer<IN>) serializer).getArity()];
    }