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}).