JuliaParallel / JuliaParallel/DistributedArrays.jl
Add gather(d::DArray{T,N,Array{T,N}}) where {T, N}
- Lenguaje dominante
- Julia
- Estrellas
- 205
- Forks
- 34
- Métricas de merge de PR
- Sin PR fusionados en 30 d
Descripción
I am wondering why it is not possible to gather a DArray{T,N,Array{T,N}}?
I wrote this method to the gather function, it works for my purpose. Maybe it is possible to add it? (or maybe I did a mistake and it should be changed somehow?)
```
function gather(d::DArray{T,N,Array{T,N}}) where {T, N}
a=Array{T}(undef, size(d))
indices = collect.(d.indices)
@sync for (i,p) in enumerate(procs(d))
@async a[indices[i]...] = remotecall_fetch(localpart, p, d)
end
a
end
```
Guía de contribución
No hay ninguna guía de contribución indexada para este repositorio
Línea de trabajo
Start by locating the existing gather function and the DArray definition in DistributedArrays.jl, then compare current gather methods with the proposed DArray{T,N,Array{T,N}} signature. Verify the behavior with a distributed array whose local parts use Array storage; done means gather returns the expected Array with all distributed indices populated.
Escrito por el modelo de indexación a partir del texto del issue.
Evaluación
- Stack tecnológico
- julia
- Área
- distributed-systems
- Tipo de issue
- Nueva funcionalidad
- Dificultad
- 3/5
- Tiempo estimado
- 1-2 días
- Estado de actividad
- Estancado
- Claridad
- Bastante claro
- Aptitud para principiantes
- 42/100