Skip to content

Commit

Permalink
fix comments.
Browse files Browse the repository at this point in the history
  • Loading branch information
Sun Rui committed Feb 15, 2015
1 parent 94066bf commit 141723e
Show file tree
Hide file tree
Showing 4 changed files with 9 additions and 1 deletion.
2 changes: 2 additions & 0 deletions pkg/R/RDD.R
Original file line number Diff line number Diff line change
Expand Up @@ -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{
Expand Down Expand Up @@ -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{
Expand Down
2 changes: 1 addition & 1 deletion pkg/inst/tests/test_rdd.R
Original file line number Diff line number Diff line change
Expand Up @@ -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) }
Expand Down
3 changes: 3 additions & 0 deletions pkg/man/aggregateRDD.Rd
Original file line number Diff line number Diff line change
Expand Up @@ -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
}

3 changes: 3 additions & 0 deletions pkg/man/fold.Rd
Original file line number Diff line number Diff line change
Expand Up @@ -31,4 +31,7 @@ rdd <- parallelize(sc, list(1, 2, 3, 4, 5))
fold(rdd, 0, "+") # 15
}
}
\seealso{
reduce
}

0 comments on commit 141723e

Please sign in to comment.