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

Тип AggregateFunction

Описание​

Все агрегатные функции в ClickHouse имеют специфическое для реализации промежуточное состояние, которое может быть сериализовано в тип данных AggregateFunction и сохранено в таблице. Обычно это реализуется с помощью материализованного представления.

С типом AggregateFunction обычно используются два комбинатора агрегатных функций:

  • Комбинатор агрегатной функции -State, который, будучи добавленным к имени агрегатной функции, создает промежуточные состояния AggregateFunction.
  • Комбинатор агрегатной функции -Merge, который используется для получения итогового результата агрегации из промежуточных состояний.

Синтаксис​

AggregateFunction(имя_агрегатной_функции, типы_аргументов...)

Параметры

  • aggregate_function_name - Имя агрегатной функции. Если функция параметризуемая, её параметры также должны быть указаны.
  • types_of_arguments - Типы аргументов агрегатной функции.

например:

CREATE TABLE t
(
    column1 AggregateFunction(uniq, UInt64),
    column2 AggregateFunction(anyIf, String, UInt8),
    column3 AggregateFunction(quantiles(0.5, 0.9), UInt64)
) ENGINE = ...

Использование​

Вставка данных​

Чтобы вставить данные в таблицу со столбцами типа AggregateFunction, вы можете использовать INSERT SELECT с агрегатными функциями и комбинатором агрегатных функций -State.

Например, чтобы вставить данные в столбцы типа AggregateFunction(uniq, UInt64) и AggregateFunction(quantiles(0.5, 0.9), UInt64), следует использовать следующие агрегатные функции с этим комбинатором.

uniqState(UserID)
quantilesState(0.5, 0.9)(SendTiming)

В отличие от функций uniq и quantiles, uniqState и quantilesState (с добавленным комбинатором -State) возвращают состояние, а не итоговое значение. Другими словами, они возвращают значение типа AggregateFunction.

В результатах запроса SELECT значения типа AggregateFunction имеют зависящее от реализации двоичное представление во всех форматах вывода ClickHouse.

Если вы экспортируете данные, например, в формат TabSeparated с помощью запроса SELECT, то затем этот дамп можно загрузить обратно с помощью запроса INSERT.

Выборка данных​

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

Агрегатная функция с добавленным к ней комбинатором -Merge принимает набор состояний, объединяет их и возвращает результат полной агрегации данных.

Например, следующие два запроса возвращают один и тот же результат:

SELECT uniq(UserID) FROM table

SELECT uniqMerge(state) FROM (SELECT uniqState(UserID) AS state FROM table GROUP BY RegionID)

Пример использования​

См. описание движка таблицы AggregatingMergeTree.

Связанные материалы​