Julia GroupedDataFrame

如何解决Julia GroupedDataFrame

我在 Julia 1.4 (DataFrames 0.22.1) 中有一个 GroupedDataFrame。我想遍历行组以计算一些统计信息。因为组多，计算慢，所以想做多线程。

代码

grouped_rows = groupby(data,by_index)
for group in grouped_rows
    # do something with `group`
end

有效，但是

grouped_rows = groupby(data,by_index)
Threads.@threads for group in grouped_rows
    # do something with `group`
end

结果为 MethodError: no method matching firstindex(::GroupedDataFrame{DataFrame})。有没有办法在 DataFrame 行组上并行化迭代？

解决方法

您需要有一个 AbstractVector 才能使 Threads.@threads 工作。

因此收集您的grouped_rows

Threads.@threads for group in collect(SubDataFrame,grouped_rows)
    # do something with `group`
end