You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by ma...@apache.org on 2013/12/19 19:39:05 UTC

[1/2] git commit: Add toString to Java RDD, and __repr__ to Python RDD

Updated Branches:
  refs/heads/master d8d3f3e60 -> 440e531a5


Add toString to Java RDD, and __repr__ to Python RDD


Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/a76f5341
Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/a76f5341
Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/a76f5341

Branch: refs/heads/master
Commit: a76f53416c0267e8a9816ee4d22fe8e838c4c319
Parents: d8d3f3e
Author: Nick Pentreath <ni...@gmail.com>
Authored: Thu Dec 19 14:38:20 2013 +0200
Committer: Nick Pentreath <ni...@gmail.com>
Committed: Thu Dec 19 14:38:20 2013 +0200

----------------------------------------------------------------------
 core/src/main/scala/org/apache/spark/api/java/JavaRDD.scala | 2 ++
 python/pyspark/rdd.py                                       | 3 +++
 2 files changed, 5 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/a76f5341/core/src/main/scala/org/apache/spark/api/java/JavaRDD.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/org/apache/spark/api/java/JavaRDD.scala b/core/src/main/scala/org/apache/spark/api/java/JavaRDD.scala
index c47657f..037cd1c 100644
--- a/core/src/main/scala/org/apache/spark/api/java/JavaRDD.scala
+++ b/core/src/main/scala/org/apache/spark/api/java/JavaRDD.scala
@@ -125,6 +125,8 @@ JavaRDDLike[T, JavaRDD[T]] {
    */
   def subtract(other: JavaRDD[T], p: Partitioner): JavaRDD[T] =
     wrapRDD(rdd.subtract(other, p))
+
+  override def toString = rdd.toString
 }
 
 object JavaRDD {

http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/a76f5341/python/pyspark/rdd.py
----------------------------------------------------------------------
diff --git a/python/pyspark/rdd.py b/python/pyspark/rdd.py
index 61720dc..7cbc66d 100644
--- a/python/pyspark/rdd.py
+++ b/python/pyspark/rdd.py
@@ -54,6 +54,9 @@ class RDD(object):
         self.ctx = ctx
         self._jrdd_deserializer = jrdd_deserializer
 
+    def __repr__(self):
+        return self._jrdd.toString()
+
     @property
     def context(self):
         """


[2/2] git commit: Merge pull request #278 from MLnick/java-python-tostring

Posted by ma...@apache.org.
Merge pull request #278 from MLnick/java-python-tostring

Add toString to Java RDD, and __repr__ to Python RDD

Addresses [SPARK-992](https://spark-project.atlassian.net/browse/SPARK-992)


Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/440e531a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/440e531a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/440e531a

Branch: refs/heads/master
Commit: 440e531a5e7720c42f0c53ce98425b63b4194b7b
Parents: d8d3f3e a76f534
Author: Matei Zaharia <ma...@databricks.com>
Authored: Thu Dec 19 10:38:56 2013 -0800
Committer: Matei Zaharia <ma...@databricks.com>
Committed: Thu Dec 19 10:38:56 2013 -0800

----------------------------------------------------------------------
 core/src/main/scala/org/apache/spark/api/java/JavaRDD.scala | 2 ++
 python/pyspark/rdd.py                                       | 3 +++
 2 files changed, 5 insertions(+)
----------------------------------------------------------------------