protected CassandraSink createWriteAheadSink()

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

18 lines of code
2 McCabe index (conditional complexity)


        protected CassandraSink<IN> createWriteAheadSink() throws Exception {
            return committer == null
                    ? new CassandraSink<>(
                            input.transform(
                                    "Cassandra Sink",
                                    null,
                                    new CassandraTupleWriteAheadSink<>(
                                            query,
                                            serializer,
                                            builder,
                                            new CassandraCommitter(builder))))
                    : new CassandraSink<>(
                            input.transform(
                                    "Cassandra Sink",
                                    null,
                                    new CassandraTupleWriteAheadSink<>(
                                            query, serializer, builder, committer)));
        }