public CassandraSink createSink()

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

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

        public CassandraSink<IN> createSink() throws Exception {
            final CassandraPojoSink<IN> sink =
                    new CassandraPojoSink<>(
                            typeInfo.getTypeClass(),
                            builder,
                            mapperOptions,
                            keyspace,
                            configBuilder.build(),
                            failureHandler);
            return new CassandraSink<>(input.addSink(sink).name("Cassandra Sink"));
        }