diff options
author | Xiangrui Meng <meng@databricks.com> | 2014-10-31 12:07:48 -0700 |
---|---|---|
committer | Josh Rosen <joshrosen@databricks.com> | 2014-10-31 12:07:48 -0700 |
commit | f1e7361f66fc24ae79bf48cc25f7fe395b016285 (patch) | |
tree | 1a2790235292a573bef6e7fee4bfefab76e40f45 /python/pyspark | |
parent | a68ecf32812b5ef150e4b455b0f13b3fe120dc80 (diff) | |
download | spark-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/pyspark')
-rw-r--r-- | python/pyspark/rdd.py | 4 |
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): """ |