in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java [78:85]
public CassandraSink<IN> name(String name) {
if (useDataStreamSink) {
getSinkTransformation().setName(name);
} else {
getTransformation().setName(name);
}
return this;
}