pyspark.BarrierTaskContext.cpusΒΆ

BarrierTaskContext.cpus() β†’ intΒΆ

CPUs allocated to the task.

Returns
int

the number of CPUs.