pyspark.TaskContext.getLocalProperty

TaskContext.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.

previous

pyspark.TaskContext.get

next

pyspark.TaskContext.partitionId