pyflink.datastream.functions.RuntimeContext.get_index_of_this_subtask

abstract RuntimeContext.get_index_of_this_subtask() → int

Gets the number of this parallel subtask. The numbering starts from 0 and goes up to parallelism-1 (parallelism as returned by get_number_of_parallel_subtasks()).