如何在 Dask 中为 GroupBy 添加自定义聚合函数？例如平均数、众数、中位数、第 95 个百分位数等
How to add custom Aggregation functions for GroupBy in Dask ? for example average, mode, median, 95th percentile etc
我无法理解以下代码中的 chunk、agg 和 finalize。
mode = dd.Aggregation('mode', chunk, agg, finalize)
同样，类型和实现方式也一样。
有人可以 guide/help 我在同一个 in Dask 吗？
参数 chunk、agg 和 finalize 在 dask.dataframe.Aggregation 的文档字符串中用示例进行了描述，可在此处在线获取：https://docs.dask.org/en/latest/dataframe-api.html#dask.dataframe.groupby.Aggregation
如果您想就该解释澄清具体问题，那么我鼓励您具体提及。
我无法理解以下代码中的 chunk、agg 和 finalize。
mode = dd.Aggregation('mode', chunk, agg, finalize)
同样，类型和实现方式也一样。 有人可以 guide/help 我在同一个 in Dask 吗？
参数 chunk、agg 和 finalize 在 dask.dataframe.Aggregation 的文档字符串中用示例进行了描述，可在此处在线获取：https://docs.dask.org/en/latest/dataframe-api.html#dask.dataframe.groupby.Aggregation
如果您想就该解释澄清具体问题，那么我鼓励您具体提及。