Unifies the implementation of lapply with lapplyParitionsWithIndex.

hlin09 · hlin09 · commit 07aa7c03e802 · 2015-02-26T15:26:10.000-05:00
diff --git a/pkg/R/RDD.R b/pkg/R/RDD.R
@@ -493,7 +493,7 @@ setMethod("lapply",
             func <- function(split, iterator) {
               lapply(iterator, FUN)
             }
-            PipelinedRDD(X, func)
+            lapplyPartitionsWithIndex(X, func)
           })
 
 #' @rdname lapply

Original file line number	Diff line number	Diff line change
`@@ -493,7 +493,7 @@ setMethod("lapply",`
`493`	`493`	`func <- function(split, iterator) {`
`494`	`494`	`lapply(iterator, FUN)`
`495`	`495`	`}`
`496`		`- PipelinedRDD(X, func)`
	`496`	`+ lapplyPartitionsWithIndex(X, func)`
`497`	`497`	`})`
`498`	`498`
`499`	`499`	`#' @rdname lapply`