Skip to content

Commit 141723e

Browse files
author
Sun Rui
committed
fix comments.
1 parent 94066bf commit 141723e

File tree

4 files changed

+9
-1
lines changed

4 files changed

+9
-1
lines changed

pkg/R/RDD.R

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1384,6 +1384,7 @@ setMethod("top",
13841384
#' @param op An associative function for the folding operation.
13851385
#' @return The folding result.
13861386
#' @rdname fold
1387+
#' @seealso reduce
13871388
#' @export
13881389
#' @examples
13891390
#'\dontrun{
@@ -1413,6 +1414,7 @@ setMethod("fold",
14131414
#' @param combOp A function to aggregate results of seqOp.
14141415
#' @return The aggregation result.
14151416
#' @rdname aggregateRDD
1417+
#' @seealso reduce
14161418
#' @export
14171419
#' @examples
14181420
#'\dontrun{

pkg/inst/tests/test_rdd.R

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -311,7 +311,7 @@ test_that("fold() on RDDs", {
311311
expect_equal(actual, 0)
312312
})
313313

314-
test_that("aggregate() on RDDs", {
314+
test_that("aggregateRDD() on RDDs", {
315315
rdd <- parallelize(sc, list(1, 2, 3, 4))
316316
zeroValue <- list(0, 0)
317317
seqOp <- function(x, y) { list(x[[1]] + y, x[[2]] + 1) }

pkg/man/aggregateRDD.Rd

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -37,4 +37,7 @@ combOp <- function(x, y) { list(x[[1]] + y[[1]], x[[2]] + y[[2]]) }
3737
aggregateRDD(rdd, zeroValue, seqOp, combOp) # list(10, 4)
3838
}
3939
}
40+
\seealso{
41+
reduce
42+
}
4043

pkg/man/fold.Rd

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -31,4 +31,7 @@ rdd <- parallelize(sc, list(1, 2, 3, 4, 5))
3131
fold(rdd, 0, "+") # 15
3232
}
3333
}
34+
\seealso{
35+
reduce
36+
}
3437

0 commit comments

Comments
 (0)