Перейти к основному содержимому
Перейти к основному содержимому

Тип SimpleAggregateFunction

Описание​

Тип данных SimpleAggregateFunction хранит промежуточное состояние агрегатной функции, но не её полное состояние, как это делает тип AggregateFunction.

Эта оптимизация может быть применена к функциям, для которых выполняется следующее свойство:

Результат применения функции f к множеству строк S1 UNION ALL S2 можно получить, применив f к частям множества строк отдельно, а затем снова применив f к результатам: f(S1 UNION ALL S2) = f(f(S1) UNION ALL f(S2)).

Это свойство гарантирует, что частичные результаты агрегации достаточно для вычисления объединенного результата, таким образом, нам не нужно хранить и обрабатывать какие-либо дополнительные данные. Например, результат функций min или max не требует дополнительных шагов для вычисления окончательного результата из промежуточных шагов, тогда как функция avg требует отслеживания суммы и количества, которые будут делиться, чтобы получить среднее значение на финальном этапе Merge, который объединяет промежуточные состояния.

Значения агрегатных функций обычно получаются путём вызова агрегатной функции с добавлением комбинирующего оператора -SimpleState к имени функции.

Синтаксис​

SimpleAggregateFunction(aggregate_function_name, types_of_arguments...)

Параметры

  • aggregate_function_name - Имя агрегатной функции.
  • Type - Типы аргументов агрегатной функции.

Поддерживаемые функции​

Поддерживаются следующие агрегатные функции:

примечание

Значения SimpleAggregateFunction(func, Type) имеют тот же Type, так что в отличие от типа AggregateFunction нет необходимости применять комбинирующие операторы -Merge/-State.

Тип SimpleAggregateFunction имеет лучшую производительность, чем AggregateFunction для тех же агрегатных функций.

Пример​

CREATE TABLE simple (id UInt64, val SimpleAggregateFunction(sum, Double)) ENGINE=AggregatingMergeTree ORDER BY id;

Связанный контент​