Repository: spark
Updated Branches:
refs/heads/master a68ecf328 -> f1e7361f6
[SPARK-4150][PySpark] return self in rdd.setName
Then we can do `rdd.setName('abc').cache().count()`.
Author: Xiangrui Meng <[email protected]>
Closes #3011 from mengxr/rdd-setname and squashes the following commits:
10d0d60 [Xiangrui Meng] update test
4ac3bbd [Xiangrui Meng] return self in rdd.setName
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/f1e7361f
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/f1e7361f
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/f1e7361f
Branch: refs/heads/master
Commit: f1e7361f66fc24ae79bf48cc25f7fe395b016285
Parents: a68ecf3
Author: Xiangrui Meng <[email protected]>
Authored: Fri Oct 31 12:07:48 2014 -0700
Committer: Josh Rosen <[email protected]>
Committed: Fri Oct 31 12:07:48 2014 -0700
----------------------------------------------------------------------
python/pyspark/rdd.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/f1e7361f/python/pyspark/rdd.py
----------------------------------------------------------------------
diff --git a/python/pyspark/rdd.py b/python/pyspark/rdd.py
index 15be4bf..550c9dd 100644
--- a/python/pyspark/rdd.py
+++ b/python/pyspark/rdd.py
@@ -1867,11 +1867,11 @@ class RDD(object):
Assign a name to this RDD.
>>> rdd1 = sc.parallelize([1,2])
- >>> rdd1.setName('RDD1')
- >>> rdd1.name()
+ >>> rdd1.setName('RDD1').name()
'RDD1'
"""
self._jrdd.setName(name)
+ return self
def toDebugString(self):
"""
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
