ну а мержи собственно происходят не всегда и не сразу

А как в запросе домерживать?

optimize final какой-то попросить?

для AMT достаточно group by в запрос добавить

GROUP BY был в запросе при создании представления

Вот я и удивляюсь, что я вижу повторы по значению колонки, по которой я делал GROUP BY

В документации же написано, При выборке данных из таблицы AggregatingMergeTree, используйте GROUP BY и те же агрегатные функции, что и при вставке данных, но с суффиксом -Merge.

Спасибо, а то я смотрю в книгу и вижу фигу

просто КХ агрегирует данные в AMT в пределах одного парта

Да, логично

Спасибо!

А что будет, если я напишу выражение, использующее агрегатные функции? Типа maxState(a) - maxState(a)? Такое будет работать?

Наверное стоит сделать два столбца, а вычислять уже при выборке?

не будет работать

Да, я вроде наконец уловил как это работает

стейты можно только мержить (складывать)

Спасибо большое!

Ребята подскажите плизз.
У меня есть макро транзакция у нее есть transaction_ID во внутрь макро транзакции включено различное количество микро транзакций каждая из которых имеет transaction_ID такой же как и у макро транзакции. Мне нужно посчитать в MV уникальное количество транзакций за период. Если я использую uniqExactMerge работает отлично, то что мне нужно. Но на большом объеме она просто вечно выполняется.

Тогда я попробовал сделать чтобы MV выбирал через GROUP BY transaction_ID, и использую sumMerge соответственно данные очень не точные получаются так как куски на которые выполняется SELECT могут соответственно содержать как макро транзакцию так и микро, в итоге GROUP BY будет возвращать правду только в рамках куска, а в итоге сумма будет не валидной.

Подскажите может быть есть какие-то варианты как можно предагрегировать uniqExactMerge так чтобы он не пересчитывал постоянно уникальные значения.

Или может какие другие варианты ?

Таблица в mv живет отдельно и не знает что в нее вставляют из mv и был выполнен какой-то select. Мержится (а все вычисления в ней происходят в момент слияния кусков и просто результат пишется в новый кусок) таблица на основании ее order by.

Раз в сутки пересчитывать (без mv) по сырым данным и писать готовые числа в таблицу.
Или считать в etl в mysql/cassandra/... до заливки в кх