Multicore und data.table in R

Question

Ich versuche multicore Funktion parallel mit data.table zu verwenden und bin nicht in der Lage, den richtigen Weg zu finden, dies zu tun. Code:

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 

Ich möchte collect() auf diese nennen, aber diese sind nicht mehr parallel Objekte. Wie sollte man das machen?

Answer 1

Ich denke, das entlang der Linien ist von dem, was Sie wollen:

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

Der Grund, warum Sie nicht parallel Objekte mehr hatte und konnte nicht laufen ein collect ist, weil man sie - Umwandlung wurden a list, anstatt sie in eine Liste zu speichern, was ich oben getan habe.