- BarrierTaskContext.partitionId()#
The ID of the RDD partition that is computed by this task.
- Returns
- int
current partition id.
pyspark.BarrierTaskContext.partitionId — PySpark In-Progress documentation
pyspark.BarrierTaskContext.partitionId — PySpark In-Progress documentation
The ID of the RDD partition that is computed by this task.
current partition id.