pyflink.datastream.data_stream.DataStream.set_parallelism# DataStream.set_parallelism(parallelism: int) → pyflink.datastream.data_stream.DataStream[source]# Sets the parallelism for this operator. Parameters parallelism – THe parallelism for this operator. Returns The operator with set parallelism.