pyflink.datastream.functions.RuntimeContext.get_number_of_parallel_subtasks

abstract RuntimeContext.get_number_of_parallel_subtasks() → int

Gets the parallelism with which the parallel task runs.