pyspark.BarrierTaskContext.getTaskInfos¶
-
BarrierTaskContext。getTaskInfos( )→列表(pyspark.taskcontext.BarrierTaskInfo] ¶ -
返回
BarrierTaskInfo這個障礙階段,所有任務的命令通過分區ID。筆記
這個API是實驗
BarrierTaskContext。
getTaskInfos
(
)→列表(pyspark.taskcontext.BarrierTaskInfo]
¶
返回BarrierTaskInfo這個障礙階段,所有任務的命令通過分區ID。
筆記
這個API是實驗