multicore e data.table in R

Question

Sto tentando di utilizzare la funzione multicoreparallel con data.table e non riesco a trovare il modo giusto per farlo. Codice:

require(multicore) 
require(data.table) 
dtb = data.table(a=1:10, b=1:2) 
x = dtb[,parallel(a+1),by=b] 

> x 
    b pid fd 
1: 1 12243 3 
2: 1 12243 6 
3: 2 12247 4 
4: 2 12247 8 

vorrei chiamare collect() su questo, ma questi non sono più parallel oggetti. Come si dovrebbe fare questo?

Answer 1

credo che questo sia lungo le linee di ciò che si vuole:

collect(dtb[, list(jobs = list(parallel(a+1))), by = b][, jobs]) 

Il motivo non ha avuto parallel oggetti più e non poteva correre un collect è perché li stavano convertendo - a list, invece di archiviarli in un elenco, che è quello che ho fatto sopra.