pyspark.Broadcast.unpersist¶
-
Broadcast.unpersist(blocking: bool = False) → None[source]¶ 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()