Skip to content
ClickHouse Docs
ClickHouse DocsClickHouse Docs
49.6kGet Started

timeSeriesResetsToGrid

View as MarkdownEdit this pageReport an issueSet up docs MCP

timeSeriesResetsToGrid

Introduzido em: v25.6.0

Função de agregação que recebe dados de série temporal como pares de timestamps e valores e calcula reset a partir desses dados em uma grade de tempo regular descrita por timestamp inicial, timestamp final e passo. Para cada ponto da grade, as amostras usadas para calcular resets são consideradas na janela de tempo especificada.

Se várias amostras tiverem o mesmo timestamp, apenas uma delas será usada: a amostra com o maior valor. Um valor NaN perde para qualquer outro valor, portanto, um valor NaN será usado somente se todas as amostras com esse timestamp forem NaN.

Sintaxe

timeSeriesResetsToGrid(start_timestamp, end_timestamp, grid_step, staleness)(timestamp, value)

Parâmetros

  • start_timestamp — Especifica o início da grade. Com um argumento de timestamp DateTime64, também pode ser um número fracionário ou uma string contendo um número ou um texto de data e hora. UInt32 ou DateTime ou DateTime64 ou Float* ou Decimal* ou String
  • end_timestamp — Especifica o fim da grade. Com um argumento de timestamp DateTime64, também pode ser um número fracionário ou uma string contendo um número ou um texto de data e hora. UInt32 ou DateTime ou DateTime64 ou Float* ou Decimal* ou String
  • grid_step — Especifica o passo da grade em segundos. Com um argumento de timestamp DateTime64, também pode ser um número fracionário ou uma string contendo um número ou uma duração como '15s' ou '1m'. UInt32 ou Float* ou Decimal* ou String
  • staleness — Especifica a "staleness" máxima, em segundos, das amostras consideradas. Com um argumento de timestamp DateTime64, também pode ser um número fracionário ou uma string contendo um número ou uma duração como '15s' ou '1m'. UInt32 ou Float* ou Decimal* ou String

Argumentos

  • timestamp — Timestamp da amostra. Pode ser um valor individual ou arrays. - value — Valor da série temporal correspondente ao timestamp. Pode ser um valor individual ou arrays.

Valor retornado

Valores de resets na grade especificada como um Array(Nullable(Float64)). O array retornado contém um valor para cada ponto da grade temporal. O valor é NULL se não houver amostras dentro da janela para calcular o valor de resets de um ponto específico da grade.

Exemplos

Calcule os valores de resets na grade [90, 105, 120, 135, 150, 165, 180, 195, 210, 225]

SET allow_experimental_time_series_aggregate_functions = 1;
WITH
    -- NOTE: the gap between 130 and 190 is to show how values are filled for ts = 180 according to window parameter
    [110, 120, 130, 190, 200, 210, 220, 230]::Array(DateTime) AS timestamps,
    [1, 3, 2, 6, 6, 4, 2, 0]::Array(Float32) AS values, -- array of values corresponding to timestamps above
    90 AS start_ts,       -- start of timestamp grid
    90 + 135 AS end_ts,   -- end of timestamp grid
    15 AS step_seconds,   -- step of timestamp grid
    45 AS window_seconds  -- "staleness" window
SELECT timeSeriesResetsToGrid(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
);
┌─timeSeriesResetsToGrid(start_ts, end_ts, step_seconds, window_seconds)(timestamp, value)─┐
│ [NULL,NULL,0,1,1,0,NULL,0,1,2]                                                           │
└──────────────────────────────────────────────────────────────────────────────────────────┘

Mesma consulta com argumentos do tipo array

SET allow_experimental_time_series_aggregate_functions = 1;
WITH
    [110, 120, 130, 190, 200, 210, 220, 230]::Array(DateTime) AS timestamps,
    [1, 3, 2, 6, 6, 4, 2, 0]::Array(Float32) AS values,
    90 AS start_ts,
    90 + 135 AS end_ts,
    15 AS step_seconds,
    45 AS window_seconds
SELECT timeSeriesResetsToGrid(start_ts, end_ts, step_seconds, window_seconds)(timestamps, values);
┌─timeSeriesResetsToGrid(start_ts, end_ts, step_seconds, window_seconds)(timestamps, values)─┐
│ [NULL,NULL,0,1,1,0,NULL,0,1,2]                                                             │
└────────────────────────────────────────────────────────────────────────────────────────────┘
Navigation