pyspark.TaskContext.getLocalProperty

TaskContext.getLocalProperty(key: str) → Optional[str][source]

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.TaskContext.get pyspark.TaskContext.partitionId