pyspark.Broadcast.unpersist

Broadcast.unpersist(blocking=False)

Delete cached copies of this broadcast on the executors. If the broadcast is used after this is called, it will need to be re-sent to each executor.

Parameters

blockingbool, optional, default False

Whether to block until unpersisting has completed.

Examples

>>> b = spark.sparkContext.broadcast([1, 2, 3, 4, 5])

Delete cached copies of this broadcast on the executors

>>> b.unpersist()