timeSeriesResampleToGridWithStaleness

Função de agregação que reamostra dados de séries temporais para a grade especificada.

​

timeSeriesResampleToGridWithStaleness

Introduzido em: v25.6.0

Função de agregação que recebe dados de séries temporais como pares de timestamps e valores e reamostra esses dados em uma grade temporal regular definida por timestamp inicial, timestamp final e passo. Para cada ponto da grade, a amostra mais recente (dentro da janela de tempo especificada) é escolhida.

Alias: timeSeriesLastToGrid.

As amostras podem ser passadas em uma de três formas:

• como dois argumentos timestamp e value, em que cada linha contém uma única amostra;
• como dois arrays de timestamps e valores, em que cada linha contém uma série temporal inteira;
• como um único array de tuplas (timestamp, value), em que cada linha contém uma série temporal inteira.

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 é usado somente se todas as amostras nesse timestamp forem NaN.

Esta função está em visualização privada; habilite-a definindo enable_time_series_aggregate_functions=true.

Sintaxe

timeSeriesResampleToGridWithStaleness(start_timestamp, end_timestamp, grid_step, staleness_window)(timestamp, value)
timeSeriesResampleToGridWithStaleness(start_timestamp, end_timestamp, grid_step, staleness_window)(samples)

Aliases: timeSeriesLastToGrid

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 que contém 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 que contém 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 que contém um número ou uma duração como ’15s’ ou ‘1m’. UInt32 ou Float* ou Decimal* ou String
• staleness_window — Especifica a desatualização máxima da amostra mais recente, em segundos. Com um argumento de timestamp DateTime64, também pode ser um número fracionário ou uma string que contém um número ou uma duração como ’15s’ ou ‘1m’. UInt32 ou Float* ou Decimal* ou String

Argumentos

• timestamp — Timestamp da amostra. Pode conter valores individuais ou arrays. UInt32 ou DateTime ou DateTime64 ou Array(UInt32) ou Array(DateTime) ou Array(DateTime64)
• value — Valor da série temporal correspondente ao timestamp. Pode conter valores individuais ou arrays. Float* ou Array(Float*)
• samples — Amostras da série temporal passadas como um array de tuplas (timestamp, value), em que os elementos da tupla têm os tipos de timestamp e valor listados acima. Uma alternativa a passar os timestamps e os valores como dois argumentos separados. Array(Tuple(T1, T2))

Valor retornado

Retorna os valores da série temporal reamostrados para a grade especificada. O array retornado contém um valor para cada ponto da grade temporal. O valor é NULL se não houver amostra para um determinado ponto da grade. Array(Nullable(Float64))

Exemplos

Uso básico com pares individuais de timestamp e valor

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 staleness 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
    30 AS window_seconds  -- "staleness" window
SELECT timeSeriesResampleToGridWithStaleness(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

┌─timeSeriesResampleToGridWithStaleness(start_ts, end_ts, step_seconds, window_seconds)(timestamp, value)─┐
│ [NULL,NULL,1,3,4,4,NULL,5,8]                                                                            │
└─────────────────────────────────────────────────────────────────────────────────────────────────────────┘

Usando argumentos do tipo Array

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,
    30 AS window_seconds
SELECT timeSeriesResampleToGridWithStaleness(start_ts, end_ts, step_seconds, window_seconds)(timestamps, values);

Response

┌─timeSeriesResampleToGridWithStaleness(start_ts, end_ts, step_seconds, window_seconds)(timestamps, values)─┐
│ [NULL,NULL,1,3,4,4,NULL,5,8]                                                                              │
└───────────────────────────────────────────────────────────────────────────────────────────────────────────┘