public void open()

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

• 12 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);

        arity = ((RowSerializer) serializer).getArity();
        fields = new Object[arity];
    }