使用降雪包并行化 R 代码

Question

我正在尝试并行运行我的 R 代码。以下是 myfunc 函数返回数字的玩具示例。

library(snowfall); 
sfInit(parallel=TRUE,cpus=5)
a <- 1 : 10000
sfExport("a")
parwrapper <- function(i){
        mysimulation <- myfunc(b=30,c=a[i])
        return(mysimulation)}
sfapply(1:10000,parwrapper)

这是我得到的错误。 checkForRemoteErrors(val) 中的错误： 5个节点产生错误；第一个错误：找不到函数“myfunc”

Answer 1

欢迎来到 SO。

错误清楚地说明了问题。 parwrapper 调用函数 myfunc。此函数未定义。此外，您可能需要导出对象sfExport('myfunc', 'parwrapper')。