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 <m...@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 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 <m...@databricks.com> Authored: Fri Oct 31 12:07:48 2014 -0700 Committer: Josh Rosen <joshro...@databricks.com> 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: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org