pyspark.BarrierTaskContext.getLocalProperty

BarrierTaskContext.getLocalProperty(key)

Get a local property set upstream in the driver, or None if it is missing.

pyspark.BarrierTaskContext.get pyspark.BarrierTaskContext.getTaskInfos