pyflink.datastream.functions.RuntimeContext.get_max_number_of_parallel_subtasks

abstract RuntimeContext.get_max_number_of_parallel_subtasks() → int

Gets the number of max-parallelism with which the parallel task runs.