From 060d2b27a95586a80b6c2a00a22feeca95b614e1 Mon Sep 17 00:00:00 2001 From: Harry Brundage Date: Thu, 27 Mar 2014 00:09:09 -0400 Subject: [PATCH] Allow the setting of a Pyspark RDD's name attribute --- python/pyspark/rdd.py | 14 ++++++++++++++ 1 file changed, 14 insertions(+) diff --git a/python/pyspark/rdd.py b/python/pyspark/rdd.py index 019c249699c2d..1f75dd430ee98 100644 --- a/python/pyspark/rdd.py +++ b/python/pyspark/rdd.py @@ -122,6 +122,20 @@ def context(self): """ return self.ctx + @property + def name(self): + """ + A friendly name for this RDD + """ + return self._jrdd.name() + + @name.setter + def name(self, name): + """ + Sets the friendly name for this RDD + """ + return self._jrdd.setName(name) + def cache(self): """ Persist this RDD with the default storage level (C{MEMORY_ONLY}).