TaskContext。
getLocalProperty
得到当地一个属性集上游的司机,或没有失踪。
以前的
pyspark.TaskContext.get
下一个
pyspark.TaskContext.partitionId