aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorStephen Haberman <stephen@exigencecorp.com>2013-01-29 00:02:17 -0600
committerStephen Haberman <stephen@exigencecorp.com>2013-01-29 00:02:17 -0600
commit951cfd9ba2a9239a777f156f10af820e9df49606 (patch)
treeb165a3bd941784c07a2737c2c0f86943471522f2
parentb45857c965219e2d26f35adb2ea3a2b831fdb77f (diff)
downloadspark-951cfd9ba2a9239a777f156f10af820e9df49606.tar.gz
spark-951cfd9ba2a9239a777f156f10af820e9df49606.tar.bz2
spark-951cfd9ba2a9239a777f156f10af820e9df49606.zip
Add JavaRDDLike.toDebugString().
-rw-r--r--core/src/main/scala/spark/api/java/JavaRDDLike.scala5
1 files changed, 5 insertions, 0 deletions
diff --git a/core/src/main/scala/spark/api/java/JavaRDDLike.scala b/core/src/main/scala/spark/api/java/JavaRDDLike.scala
index 4c95c989b5..44f778e5c2 100644
--- a/core/src/main/scala/spark/api/java/JavaRDDLike.scala
+++ b/core/src/main/scala/spark/api/java/JavaRDDLike.scala
@@ -330,4 +330,9 @@ trait JavaRDDLike[T, This <: JavaRDDLike[T, This]] extends PairFlatMapWorkaround
case _ => Optional.absent()
}
}
+
+ /** A description of this RDD and its recursive dependencies for debugging. */
+ def toDebugString(): String = {
+ rdd.toDebugString()
+ }
}