pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment.get_max_parallelism#

StreamExecutionEnvironment.get_max_parallelism() → int[source]#

Gets the maximum degree of parallelism defined for the program.

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