pyspark.BarrierTaskContext.getTaskInfos¶
-
BarrierTaskContext。getTaskInfos( )→列表(pyspark.taskcontext.BarrierTaskInfo] ¶ -
返回
BarrierTaskInfo这个障碍阶段,所有任务的命令通过分区ID。笔记
这个API是实验
BarrierTaskContext。
getTaskInfos
(
)→列表(pyspark.taskcontext.BarrierTaskInfo]
¶
返回BarrierTaskInfo这个障碍阶段,所有任务的命令通过分区ID。
笔记
这个API是实验