code: public CassandraSink<IN> setParallelism(int parallelism) {
  		if (useDataStreamSink) {
  			getSinkTransformation().setParallelism(parallelism);
  		} else {
  			getStreamTransformation().setParallelism(parallelism);
  		}
  		return this;
  	}
docs: Sets the parallelism for this sink. The degree must be higher than zero.
  
  @param parallelism The parallelism for this sink.
  @return The sink with set parallelism.