pyspark.BarrierTaskContext.getLocalProperty

BarrierTaskContext.getLocalProperty(key: str) → Optional[str]

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

Parameters

keystr

the key of the local property to get.

Returns

int

the value of the local property.

pyspark.BarrierTaskContext.get pyspark.BarrierTaskContext.getTaskInfos