flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java [518:525]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                                            query,
                                            serializer,
                                            builder,
                                            new CassandraCommitter(builder))))
                    : new CassandraSink<>(
                            input.transform(
                                    "Cassandra Sink",
                                    null,
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java [572:579]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                                            query,
                                            serializer,
                                            builder,
                                            new CassandraCommitter(builder))))
                    : new CassandraSink<>(
                            input.transform(
                                    "Cassandra Sink",
                                    null,
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -