Skip to content

Commit f1e7361

Browse files
mengxrJoshRosen
authored andcommitted
[SPARK-4150][PySpark] return self in rdd.setName
Then we can do `rdd.setName('abc').cache().count()`. Author: Xiangrui Meng <[email protected]> Closes apache#3011 from mengxr/rdd-setname and squashes the following commits: 10d0d60 [Xiangrui Meng] update test 4ac3bbd [Xiangrui Meng] return self in rdd.setName
1 parent a68ecf3 commit f1e7361

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

python/pyspark/rdd.py

+2-2
Original file line numberDiff line numberDiff line change
@@ -1867,11 +1867,11 @@ def setName(self, name):
18671867
Assign a name to this RDD.
18681868
18691869
>>> rdd1 = sc.parallelize([1,2])
1870-
>>> rdd1.setName('RDD1')
1871-
>>> rdd1.name()
1870+
>>> rdd1.setName('RDD1').name()
18721871
'RDD1'
18731872
"""
18741873
self._jrdd.setName(name)
1874+
return self
18751875

18761876
def toDebugString(self):
18771877
"""

0 commit comments

Comments
 (0)