pyflink.datastream.data_stream.DataStream.set_max_parallelism

DataStream.set_max_parallelism(max_parallelism: int) → 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.