deltaSumTimestamp

Добавлена в версии: v21.6

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

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

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

Синтаксис

deltaSumTimestamp(value, timestamp)

Аргументы

value — Входные значения. (U)Int* или Float* или Date или DateTime
timestamp — Параметр для упорядочения значений. (U)Int* или Float* или Date или DateTime

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

Возвращает накопленные разности между последовательными значениями, упорядоченными по параметру timestamp. (U)Int* или 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 │
└─────────────────────────────────────┘

deltaSumTimestamp​

deltaSumTimestamp