pyspark.BarrierTaskInfo¶

class pyspark.BarrierTaskInfo(address)[source]¶

Carries all task infos of a barrier task.

New in version 2.4.0.

Notes

This API is experimental

Attributes:

addressstr: The IPv4 address (host:port) of the executor that the barrier task is running on

pyspark.BarrierTaskContext pyspark.InheritableThread