我正在尝试doParallel
用于并行化我的查询。我正在尝试col_funcs
在同一个脚本中使用该函数bsp_functions.R
。
#install.packages("doParallel")
library(doParallel)
cl <- makeCluster(3)
registerDoParallel(cl, cores=1)
path <- ("~/Combined/")
source(paste(path, "bsp_functions.R", sep=""))
res <- bsn(data=data, outcome=outcome)
#bsp_functions.R
bsn <- function(data, outcome){
rs_fun <- foreach(i=1:length(sets), .combine=rbind) %dopar% {
list['data.temp', 'sets'] <- col_funcs(data, set)
}
}
col_funcs <- function(data, set){
# processing
}
它给出了以下错误:
Error:
Error in { : task 1 failed - "could not find function "col_funcs""
看完这篇文章后.export
,我通过将函数传递给全局环境来更改我的代码如下。
rs_fun <- foreach(i=1:length(sets), .combine=rbind, .export='col_funcs') %dopar% {
现在,它给出了以下错误。
Error in { :
task 1 failed - "object of type 'builtin' is not subsettable"
任何帮助,将不胜感激。