parallel, Forech exportierte Objekt nicht

Question

gefunden ich habe folgende (Probe) Code, der im passiven Modus auf Rechencluster ausgeführt wird:

> foo <- function(...) 
> { 
> require(copula) 
> require(foreach) 
> require(methods) 
> require(np) 
> require(parallel) 
> {cl <- makeCluster(detectCores()-1) ; registerDoParallel(cl)} 
... 
> str(dat) 
'data.frame': 31269 obs. of 15 variables 
... 
> clusterExport(cl=cl,varlist=c("dat",...)) 
> dumpster <- foreach(i=1:10,.packages=c("copula","foreach","np"),.export=c("dat"))%dopar% 
> {... ; dat.new <- some.fn(dat) ; ...} 
... 
> stopCluster(cl) 
> } 
> foo(...) 
Error in get(name, envir = envir) : object 'dat' not found 
Calls: foo ... postNode -> sendData -> sendData.SOCKnode -> serialize -> get 
Execution halted 

Was mache ich falsch? Vielen Dank!

Answer 1

Sie haben einige Anweisungen gemischt, um um diese

library(doSNOW) 
library(foreach) 
cl <- makeCluster(detectCores()-1, type = "SOCK") 
registerDoSNOW(cl) 

Ich gehe davon aus auszukommen, dass das Objekt dat bereits availaible war und so ist dies, wie Sie die foreach verwenden

dumpster <- foreach(i=1:10,.packages=c("copula","np"), .combine = c)%dopar%{dat.new <- some.fn(dat)} 

Dann schließen Sie die Cluster

stopCluster(cl)