public CassandraSink slotSharingGroup()

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

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

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