aboutsummaryrefslogtreecommitdiff
path: root/python/pyspark/broadcast.py
diff options
context:
space:
mode:
Diffstat (limited to 'python/pyspark/broadcast.py')
-rw-r--r--python/pyspark/broadcast.py3
1 files changed, 3 insertions, 0 deletions
diff --git a/python/pyspark/broadcast.py b/python/pyspark/broadcast.py
index 5c7c9cc161..f124dc6c07 100644
--- a/python/pyspark/broadcast.py
+++ b/python/pyspark/broadcast.py
@@ -78,6 +78,9 @@ class Broadcast(object):
return self._value
def unpersist(self, blocking=False):
+ """
+ Delete cached copies of this broadcast on the executors.
+ """
self._jbroadcast.unpersist(blocking)
os.unlink(self.path)