Вычисление сгруппированных медиан в DolphinDB

Question

У меня есть таблица DFS в DolphinDB. Я попытался выполнить запрос, который вычислил бы сгруппированные медианы для этой таблицы. Но это только бросило исключение.

select median(col1) from t group by col2

Агрегированная функция в столбце med (v1) не имеет реализации сокращения карт и не может быть применена к секционированной или распределенной таблице.

Мне кажется, что 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})