aboutsummaryrefslogtreecommitdiff
path: root/python
diff options
context:
space:
mode:
authorXiangrui Meng <meng@databricks.com>2014-10-31 12:07:48 -0700
committerJosh Rosen <joshrosen@databricks.com>2014-10-31 12:07:48 -0700
commitf1e7361f66fc24ae79bf48cc25f7fe395b016285 (patch)
tree1a2790235292a573bef6e7fee4bfefab76e40f45 /python
parenta68ecf32812b5ef150e4b455b0f13b3fe120dc80 (diff)
downloadspark-f1e7361f66fc24ae79bf48cc25f7fe395b016285.tar.gz
spark-f1e7361f66fc24ae79bf48cc25f7fe395b016285.tar.bz2
spark-f1e7361f66fc24ae79bf48cc25f7fe395b016285.zip
[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
Diffstat (limited to 'python')
-rw-r--r--python/pyspark/rdd.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/python/pyspark/rdd.py b/python/pyspark/rdd.py
index 15be4bfec9..550c9dd805 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):
"""