pyspark.BarrierTaskContext.getTaskInfos

BarrierTaskContext.getTaskInfos() → List[pyspark.taskcontext.BarrierTaskInfo]

Returns BarrierTaskInfo for all tasks in this barrier stage, ordered by partition ID.

Notes

This API is experimental

previous

pyspark.BarrierTaskContext.getLocalProperty

next

pyspark.BarrierTaskContext.partitionId