public CassandraSink setParallelism()

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

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

    public CassandraSink<IN> setParallelism(int parallelism) {
        if (useDataStreamSink) {
            sink1.setParallelism(parallelism);
        } else {
            sink2.setParallelism(parallelism);
        }
        return this;
    }