public CassandraSink setUidHash()

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

• 8 lines of code
• 2 McCabe index (conditional complexity)

    public CassandraSink<IN> setUidHash(String uidHash) {
        if (useDataStreamSink) {
            getSinkTransformation().setUidHash(uidHash);
        } else {
            getTransformation().setUidHash(uidHash);
        }
        return this;
    }