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