From 141723eeed1cd032931e112a3d11c7f57c9c72c9 Mon Sep 17 00:00:00 2001 From: Sun Rui Date: Sun, 15 Feb 2015 10:25:11 +0800 Subject: [PATCH] fix comments. --- pkg/R/RDD.R | 2 ++ pkg/inst/tests/test_rdd.R | 2 +- pkg/man/aggregateRDD.Rd | 3 +++ pkg/man/fold.Rd | 3 +++ 4 files changed, 9 insertions(+), 1 deletion(-) diff --git a/pkg/R/RDD.R b/pkg/R/RDD.R index 39f054b9ba67a..b23e13db31b61 100644 --- a/pkg/R/RDD.R +++ b/pkg/R/RDD.R @@ -1384,6 +1384,7 @@ setMethod("top", #' @param op An associative function for the folding operation. #' @return The folding result. #' @rdname fold +#' @seealso reduce #' @export #' @examples #'\dontrun{ @@ -1413,6 +1414,7 @@ setMethod("fold", #' @param combOp A function to aggregate results of seqOp. #' @return The aggregation result. #' @rdname aggregateRDD +#' @seealso reduce #' @export #' @examples #'\dontrun{ diff --git a/pkg/inst/tests/test_rdd.R b/pkg/inst/tests/test_rdd.R index dff91179c6495..89d7890fbf685 100644 --- a/pkg/inst/tests/test_rdd.R +++ b/pkg/inst/tests/test_rdd.R @@ -311,7 +311,7 @@ test_that("fold() on RDDs", { expect_equal(actual, 0) }) -test_that("aggregate() on RDDs", { +test_that("aggregateRDD() on RDDs", { rdd <- parallelize(sc, list(1, 2, 3, 4)) zeroValue <- list(0, 0) seqOp <- function(x, y) { list(x[[1]] + y, x[[2]] + 1) } diff --git a/pkg/man/aggregateRDD.Rd b/pkg/man/aggregateRDD.Rd index b64936aa8482f..16a0fbe4cb3b3 100644 --- a/pkg/man/aggregateRDD.Rd +++ b/pkg/man/aggregateRDD.Rd @@ -37,4 +37,7 @@ combOp <- function(x, y) { list(x[[1]] + y[[1]], x[[2]] + y[[2]]) } aggregateRDD(rdd, zeroValue, seqOp, combOp) # list(10, 4) } } +\seealso{ +reduce +} diff --git a/pkg/man/fold.Rd b/pkg/man/fold.Rd index e0d22d23e3b79..f2253d3f34fa9 100644 --- a/pkg/man/fold.Rd +++ b/pkg/man/fold.Rd @@ -31,4 +31,7 @@ rdd <- parallelize(sc, list(1, 2, 3, 4, 5)) fold(rdd, 0, "+") # 15 } } +\seealso{ +reduce +}