dask - 如何在 Dask 中为 GroupBy 添加自定义聚合函数？例如平均值、众数、中位数、第 95 个百分位数等

Question

我无法理解以下代码中的块、聚合和最终确定。

mode = dd.Aggregation('mode', chunk, agg, finalize)

此外，类型和实现方式相同。有人可以在 Dask 中指导/帮助我吗？

Answer 1

参数chunk、agg和finalize用文档字符串中的示例进行描述，dask.dataframe.Aggregation可在此处在线获取：https ://docs.dask.org/en/latest/dataframe-api.html#dask.dataframe.groupby.Aggregation

如果您有关于该解释的特定问题想要澄清，那么我鼓励您具体提及它们。