From a76f53416c0267e8a9816ee4d22fe8e838c4c319 Mon Sep 17 00:00:00 2001
From: Nick Pentreath <nick.pentreath@gmail.com>
Date: Thu, 19 Dec 2013 14:38:20 +0200
Subject: [PATCH] Add toString to Java RDD, and __repr__ to Python RDD
---
core/src/main/scala/org/apache/spark/api/java/JavaRDD.scala | 2 ++
python/pyspark/rdd.py | 3 +++
2 files changed, 5 insertions(+)
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 c47657f512..037cd1c774 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 {
diff --git a/python/pyspark/rdd.py b/python/pyspark/rdd.py
index 61720dcf1a..7cbc66d3c9 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):
"""
--
GitLab