pyspark.BarrierTaskContext.get

类方法 BarrierTaskContext. 获取 高山市 )→ pyspark.taskcontext.BarrierTaskContext

返回当前活动BarrierTaskContext.可调用用户函数内部存取运行任务背景信息

注解

必须调用工人而非驱动返回不初始化则不返回异常点若非阻塞阶段会提高

API实验

前一

pyspark.BarrierTaskContext.barrier

下一个

pyspark.BarrierTaskContext.getLocalProperty