pyflink.datastream.data_stream.DataStream.force_non_parallel

DataStream.force_non_parallel() → DataStream

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.