Skip to content
Snippets Groups Projects
Commit f1e7361f authored by Xiangrui Meng's avatar Xiangrui Meng Committed by Josh Rosen
Browse files

[SPARK-4150][PySpark] return self in rdd.setName

Then we can do `rdd.setName('abc').cache().count()`.

Author: Xiangrui Meng <meng@databricks.com>

Closes #3011 from mengxr/rdd-setname and squashes the following commits:

10d0d60 [Xiangrui Meng] update test
4ac3bbd [Xiangrui Meng] return self in rdd.setName
parent a68ecf32
No related branches found
No related tags found
No related merge requests found
...@@ -1867,11 +1867,11 @@ class RDD(object): ...@@ -1867,11 +1867,11 @@ class RDD(object):
Assign a name to this RDD. Assign a name to this RDD.
>>> rdd1 = sc.parallelize([1,2]) >>> rdd1 = sc.parallelize([1,2])
>>> rdd1.setName('RDD1') >>> rdd1.setName('RDD1').name()
>>> rdd1.name()
'RDD1' 'RDD1'
""" """
self._jrdd.setName(name) self._jrdd.setName(name)
return self
def toDebugString(self): def toDebugString(self):
""" """
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment