使用降雪包并行化 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)

这是我得到的错误。 检查远程错误(val(中的错误： 5个节点产生错误;第一个错误：找不到函数"myfunc">

Answer 1

欢迎来到 SO。

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