[使用降雪包的Parallelize 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

欢迎您加入。

错误明确指出了问题所在。 parwrapper调用功能myfunc。未定义此功能。另外，您可能必须导出对象sfExport('myfunc', 'parwrapper')。