从R包到集群的导出功能(并行处理)



我正试图再次使用parLapply(现在成功地在此上下文中使用它),但这次并行化的函数包含来自mc2d包的一些函数(即。deprt ppert)。我安装并加载了这个包,之前是并行部分的代码。

我使用集群导出成功地将变量导出到集群,

clusterExport(C1, "variable")
...

然而,我尝试使用

导出函数dpert和ppert
clusterEvalQ(C1,dpert)

得到错误

object C1 not found

怎么找不到C1?是否有另一种方法将R-packages函数导出到集群以进行并行处理?

为函数使用clusterExport…

clusterExport(Cl,c('dpert','variable'))

我偶然发现的另一种方法是在函数调用之前添加函数所属的包的名称。例如,在parLapply()(或任何其他parallel库函数)中使用rlang::syms()dplyr::group_indices()而不是说syms()group_indices()

最新更新