pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment.get_parallelism

StreamExecutionEnvironment.get_parallelism() → int

Gets the parallelism with which operation are executed by default. Operations can individually override this value to use a specific parallelism.

Returns:

The parallelism used by operations, unless they override that value.