sql - 在 DolphinDB 中计算分组中位数

Question

我在 DolphinDB 中有一个 DFS 表。我试图运行一个查询来计算该表上的分组中位数。但它只是抛出了一个异常。

select median(col1) from t group by col2

med(v1) 列中的聚合函数没有 map-reduce 实现，不能应用于分区表或分布式表。

在我看来，DolphinDB 不支持分布式中值算法。

Answer 1

聚合函数的median不同之处avgerage在于它不能通过 map-reduce 来解决。所以我们必须提取数据，然后将中值函数应用于每个组。

DolphinDB 的重新分区机制使此类工作变得更加容易。

ds = repartitionDS(<select first(col2) as col2, median(col1) as col1 from t>,`col2, VALUE)
mr(ds, x->x,,unionAll{false})