pyflink.datastream.data_stream.DataStream.set_max_parallelism

DataStream.set_max_parallelism(max_parallelism: int) → pyflink.datastream.data_stream.DataStream

Sets the maximum parallelism of this operator.

The maximum parallelism specifies the upper bound for dynamic scaling. It also defines the number of key groups used for partitioned state.

Parameters

max_parallelism – Maximum parallelism.

Returns

The operator with set maximum parallelism.