mapply_rdd: Apply a Function to multiple rddlist arguments

In clarkfitzg/rddlist: An R list as a Spark RDD (resilient distributed dataset)

Description

Modeled after mapply in base R

Usage

mapply_rdd(FUN, ..., cache = TRUE)

Arguments

FUN	function to apply to each element of X
...	rddlists of the same length
cache	logical - Should the resulting RDD be cached in Spark's memory?

Value

rddlist A Spark Java Object representing the resulting rddlist

Examples

x <- rddlist(sc, list(1:10, letters, rnorm(10)))
y <- rddlist(sc, list(21:30, LETTERS, rnorm(10)))
xy <- mapply_rdd(c, x, y)

clarkfitzg/rddlist documentation built on May 13, 2019, 7:35 p.m.