Wielordzeniowe i data.table w R

Próbuję użyć funkcji multicoreparallel z data.table i nie jestem w stanie wymyślić właściwą drogę, aby to zrobić. Kod:Wielordzeniowe i data.table w R

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

Chciałbym zadzwonić collect() na ten temat, ale te nie są już parallel obiekty. Jak to zrobić?

Źródło

2013-02-04 Alex

Co jest nie tak z 'x = dtb [, collect (równolegle (a + 1)), by = b]'? – Ryogi

zbierać czeka na równoległe do końca – Alex

@alex trudno zrozumieć, dlaczego collect() oczekiwania na równoległość() jest problemem. Trudno jest również ekstrapolować twój przykład na prawdziwy problem i dlatego wiesz, czego tak naprawdę chcesz od tego. Czy możesz nam pomóc zrozumieć? – ndoogan

myślę, że to jest wzdłuż linii, co chcesz:

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

Powodem nie masz parallel obiektów dłużej i nie mógł uruchomić collect dlatego, że zostały przekształcając je do a list, zamiast przechowywać je w postaci listy, co zrobiłem powyżej.

Źródło

2013-04-30 20:44:41 eddi

Wielordzeniowe i data.table w R

Odpowiedz

Powiązane problemy