public CassandraSink build()

in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java [459:465]

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

        public CassandraSink<IN> build() throws Exception {
            sanityCheck();
            if (failureHandler == null) {
                failureHandler = new NoOpCassandraFailureHandler();
            }
            return isWriteAheadLogEnabled ? createWriteAheadSink() : createSink();
        }