You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by sh...@apache.org on 2015/05/11 04:49:46 UTC
spark git commit: [SPARK-7512] [SPARKR] Fix RDD's show method to use
getJRDD
Repository: spark
Updated Branches:
refs/heads/master c5aca0c27 -> 0835f1edd
[SPARK-7512] [SPARKR] Fix RDD's show method to use getJRDD
Since the RDD object might be a Pipelined RDD we should use `getJRDD` to get the right handle to the Java object.
Fixes the bug reported at
http://stackoverflow.com/questions/30057702/sparkr-filterrdd-and-flatmap-not-working
cc concretevitamin
Author: Shivaram Venkataraman <sh...@cs.berkeley.edu>
Closes #6035 from shivaram/sparkr-show-bug and squashes the following commits:
d70145c [Shivaram Venkataraman] Fix RDD's show method to use getJRDD Fixes the bug reported at http://stackoverflow.com/questions/30057702/sparkr-filterrdd-and-flatmap-not-working
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/0835f1ed
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/0835f1ed
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/0835f1ed
Branch: refs/heads/master
Commit: 0835f1edd4c9c05439df85c248faf6787d45f7b7
Parents: c5aca0c
Author: Shivaram Venkataraman <sh...@cs.berkeley.edu>
Authored: Sun May 10 19:49:42 2015 -0700
Committer: Shivaram Venkataraman <sh...@cs.berkeley.edu>
Committed: Sun May 10 19:49:42 2015 -0700
----------------------------------------------------------------------
R/pkg/R/RDD.R | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/0835f1ed/R/pkg/R/RDD.R
----------------------------------------------------------------------
diff --git a/R/pkg/R/RDD.R b/R/pkg/R/RDD.R
index 73999a6..9138629 100644
--- a/R/pkg/R/RDD.R
+++ b/R/pkg/R/RDD.R
@@ -67,8 +67,8 @@ setMethod("initialize", "RDD", function(.Object, jrdd, serializedMode,
})
setMethod("show", "RDD",
- function(.Object) {
- cat(paste(callJMethod(.Object@jrdd, "toString"), "\n", sep=""))
+ function(object) {
+ cat(paste(callJMethod(getJRDD(object), "toString"), "\n", sep=""))
})
setMethod("initialize", "PipelinedRDD", function(.Object, prev, func, jrdd_val) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org