pyflink.datastream.data_stream.DataStream.force_non_parallel# DataStream.force_non_parallel() → pyflink.datastream.data_stream.DataStream[source]# Sets the parallelism and maximum parallelism of this operator to one. And mark this operator cannot set a non-1 degree of parallelism. Returns The operator with only one parallelism.