1

我正在尝试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" 

任何帮助,将不胜感激。

4

0 回答 0