timeSeriesStddevToGrid

Добавлена в: v26.10.0 Агрегатная функция, которая принимает данные временных рядов в виде пар временных меток и значений и вычисляет по ним PromQL-подобную функцию stddev_over_time (стандартное отклонение генеральной совокупности) на регулярной временной сетке, заданной начальной временной меткой, конечной временной меткой и шагом. Для каждой точки сетки при вычислении stddev_over_time учитываются образцы, попадающие в заданное временное окно. Образцы можно передавать в одной из трёх форм:

в виде двух аргументов timestamp и value, где каждая строка содержит один образец;
в виде двух массивов временных меток и значений, где каждая строка содержит целый временной ряд;
в виде одного массива Tuple (timestamp, value), где каждая строка содержит целый временной ряд.

Если у нескольких образцов совпадает временная метка, используется только один из них — образец с наибольшим значением. Значение NaN уступает любому другому значению, поэтому NaN используется, только если все образцы с этой временной меткой равны NaN.

Эта функция находится в закрытой предварительной версии. Чтобы включить её, задайте настройку enable_time_series_aggregate_functions=true.

Синтаксис

timeSeriesStddevToGrid(start_timestamp, end_timestamp, grid_step, staleness)(timestamp, value)
timeSeriesStddevToGrid(start_timestamp, end_timestamp, grid_step, staleness)(samples)

Параметры

start_timestamp — Задаёт начало сетки. Также может быть дробным числом или строкой, содержащей число или текстовое представление даты и времени. UInt32 или DateTime или DateTime64 или Float* или Decimal* или String
end_timestamp — Задаёт конец сетки. Также может быть дробным числом или строкой, содержащей число или текстовое представление даты и времени. UInt32 или DateTime или DateTime64 или Float* или Decimal* или String
grid_step — Задаёт шаг сетки в секундах. Также может быть дробным числом или строкой, содержащей число или длительность, например ’15s’ или ‘1m’. UInt32 или Float* или Decimal* или String
staleness — Задаёт максимальную давность (в секундах) учитываемых образцов. Окно давности представляет собой интервал, открытый слева и закрытый справа. Также может быть дробным числом или строкой, содержащей число или длительность, например ’15s’ или ‘1m’. UInt32 или Float* или Decimal* или String

Аргументы

timestamp — Временная метка образца. Может быть отдельным значением или массивом. UInt32 или DateTime или DateTime64 или Array(UInt32) или Array(DateTime) или Array(DateTime64)
value — Значение временного ряда, соответствующее временной метке. Может быть отдельным значением или массивом. Float* или Array(Float*)
samples — Образцы временного ряда, передаваемые в виде массива Tuple (timestamp, value), элементы которых имеют указанные выше типы временной метки и значения. Альтернатива передаче временных меток и значений в виде двух отдельных аргументов. Array(Tuple(T1, T2))

Возвращаемое значение Возвращает значения стандартного отклонения генеральной совокупности на заданной сетке. Возвращаемый массив содержит по одному значению для каждой точки временной сетки. Если для какой-либо точки сетки в окне нет образцов, значение равно NULL. Array(Nullable(Float64)) Примеры Базовое использование с отдельными парами «временная метка — значение»

Query

SET enable_time_series_aggregate_functions = 1;
WITH
    -- NOTE: the gap between 140 and 190 is to show how values are filled for ts = 150, 165, 180 according to window parameter
    [110, 120, 130, 140, 190, 200, 210, 220, 230]::Array(DateTime) AS timestamps,
    [1, 1, 3, 4, 5, 5, 8, 12, 13]::Array(Float32) AS values, -- array of values corresponding to timestamps above
    90 AS start_ts,       -- start of timestamp grid
    90 + 120 AS end_ts,   -- end of timestamp grid
    15 AS step_seconds,   -- step of timestamp grid
    45 AS window_seconds  -- "staleness" window
SELECT timeSeriesStddevToGrid(start_ts, end_ts, step_seconds, window_seconds)(timestamp, value)
FROM
(
    -- This subquery converts arrays of timestamps and values into rows of `timestamp`, `value`
    SELECT
        arrayJoin(arrayZip(timestamps, values)) AS ts_and_val,
        ts_and_val.1 AS timestamp,
        ts_and_val.2 AS value
);

Response

┌─timeSeriesStddevToGrid(start_ts, end_ts, step_seconds, window_seconds)(timestamp, value)─┐
│ [NULL,NULL,0,0.9428090415820634,1.299038105676658,0.5,0,0,1.4142135623730951]            │
└──────────────────────────────────────────────────────────────────────────────────────────┘

Использование массивов в качестве аргументов

Query

SET enable_time_series_aggregate_functions = 1;
WITH
    [110, 120, 130, 140, 190, 200, 210, 220, 230]::Array(DateTime) AS timestamps,
    [1, 1, 3, 4, 5, 5, 8, 12, 13]::Array(Float32) AS values,
    90 AS start_ts,
    90 + 120 AS end_ts,
    15 AS step_seconds,
    45 AS window_seconds
SELECT timeSeriesStddevToGrid(start_ts, end_ts, step_seconds, window_seconds)(timestamps, values);

Response

┌─timeSeriesStddevToGrid(start_ts, end_ts, step_seconds, window_seconds)(timestamps, values)─┐
│ [NULL,NULL,0,0.9428090415820634,1.299038105676658,0.5,0,0,1.4142135623730951]              │
└────────────────────────────────────────────────────────────────────────────────────────────┘

Справочник по SQL

Типы данных

Движки

Функции

Форматы

Настройки

Системные таблицы

Озера данных

timeSeriesStddevToGrid

timeSeriesStddevToGrid

​timeSeriesStddevToGrid

timeSeriesStddevToGrid