本人使用spark1.4中的sparkR时,有一个函数parallelize()一直找不到其所在的包是哪个,哪位大侠知道啊?
library(SparkR)
library(testthat)
context("test functions in sparkR.R")
test_that("repeatedly starting and stopping SparkR", {
for (i in 1:4) {
sc <- sparkR.init()
rdd <- parallelize(sc, 1:20, 2L)
expect_equal(count(rdd), 20)
sparkR.stop()
}
})
以上执行parallelize()时报错Error: could not find function "parallelize"