альтер и поделить все значения на 1000?
Над SimpleAggFunc можно вроде было
create table amt(k UInt64, b AggregateFunction(sum, UInt64) ) Engine=AggregatingMergeTree order by k; insert into amt select number%1000 g, sumState(number) from numbers(1000000000) group by g; select sumMerge(b) from amt; ┌────────sumMerge(b)─┐ │ 499999999500000000 │ └────────────────────┘ select k, finalizeAggregation(b) y, intDiv(y,1000) y1, finalizeAggregation(initializeAggregation('sumState', intDiv(finalizeAggregation(b),1000)) ) x, x=y1 w from amt limit 10; ┌─k─┬───────────────y─┬───────────y1─┬────────────x─┬─w─┐ │ 0 │ 499999500000000 │ 499999500000 │ 499999500000 │ 1 │ │ 1 │ 499999501000000 │ 499999501000 │ 499999501000 │ 1 │ │ 2 │ 499999502000000 │ 499999502000 │ 499999502000 │ 1 │ │ 3 │ 499999503000000 │ 499999503000 │ 499999503000 │ 1 │ │ 4 │ 499999504000000 │ 499999504000 │ 499999504000 │ 1 │ │ 5 │ 499999505000000 │ 499999505000 │ 499999505000 │ 1 │ │ 6 │ 499999506000000 │ 499999506000 │ 499999506000 │ 1 │ │ 7 │ 499999507000000 │ 499999507000 │ 499999507000 │ 1 │ │ 8 │ 499999508000000 │ 499999508000 │ 499999508000 │ 1 │ │ 9 │ 499999509000000 │ 499999509000 │ 499999509000 │ 1 │ └───┴─────────────────┴──────────────┴──────────────┴───┘ alter table amt update b=initializeAggregation('sumState', intDiv(finalizeAggregation(b),1000)) where 1; select sumMerge(b) from amt; ┌─────sumMerge(b)─┐ │ 499999999500000 │ └─────────────────┘ 499999999500000000 499999999500000
забыл написать, обязателно проверьте на стейдже, на своих данных
Непременно, спасибо!
Обсуждают сегодня