deltaSumTimestamp

Добавляет разность между последовательными строками. Если разность отрицательная, она игнорируется.

Эта функция в первую очередь предназначена для materialized views, которые хранят данные, упорядоченные по метке времени, приведённой к шагу временного бакета, например, к бакету toStartOfMinute. Поскольку строки в таком materialized view имеют одинаковую метку времени, их невозможно корректно объединить в нужном порядке без хранения исходного, неокруглённого значения метки времени. Функция deltaSumTimestamp отслеживает исходный timestamp значений, которые были обработаны, поэтому значения (состояния) функции корректно вычисляются во время слияния частей.

Чтобы вычислить сумму дельт по упорядоченной коллекции, вы можете просто использовать функцию deltaSum.

Синтаксис

deltaSumTimestamp(value, timestamp)

Аргументы

• value — Входные значения. Должны иметь тип Integer, Float, Date или DateTime.
• timestamp — Параметр для упорядочивания значений. Должен иметь тип Integer, Float, Date или DateTime.

Возвращаемое значение

• Накопленные разности между последовательными значениями, упорядоченными по параметру timestamp.

Тип: Integer, Float, Date или DateTime.

Пример

Запрос:

SELECT deltaSumTimestamp(value, timestamp)
FROM (SELECT number AS timestamp, [0, 4, 8, 3, 0, 0, 0, 1, 3, 5][number] AS value FROM numbers(1, 10));

Результат:

┌─deltaSumTimestamp(value, timestamp)─┐
│                                  13 │
└─────────────────────────────────────┘