timeSeriesTopKMasks

Selecciona las series temporales con los k valores más altos en cada paso de la cuadrícula.

​

timeSeriesTopKMasks

Introducido en: v26.8.0

Selecciona las series temporales con los k valores más altos en cada paso de una cuadrícula temporal.

Cada fila de entrada es una serie temporal: key identifica la serie y values contiene sus valores alineados con una cuadrícula temporal común, por lo que los arrays values de todas las filas deben tener el mismo tamaño. En cada paso temporal, se seleccionan las series con los k valores no NULL más altos en ese paso (NaN se considera menor que cualquier otro valor). Los empates se resuelven dando preferencia a la serie con la key más pequeña.

Esta función implementa el operador de agregación topk() de PromQL y mantiene un único heap acotado de tamaño k por paso temporal, por lo que el tamaño de su estado no depende del número de series agregadas.

Esta función está en vista previa privada; para habilitarla, establezca enable_time_series_aggregate_functions = 1.

Sintaxis

timeSeriesTopKMasks(k, key, values)

Argumentos

• k — Número de series que se seleccionan en cada paso de tiempo: un único valor para todos los pasos de tiempo o un array con un valor por paso de tiempo. Debe ser el mismo para todas las filas. UInt* o Array(UInt*)
• key — Identificador de la serie temporal. UInt64
• values — Valores de la serie temporal alineados con la cuadrícula temporal, un elemento por paso de tiempo. Array(Nullable(Float32)) o Array(Nullable(Float64)) o Array(Float32) o Array(Float64)

Valor devuelto

Devuelve las series seleccionadas ordenadas de forma ascendente por key, cada una junto con su máscara por paso: steps_mask[t] = 1 si la serie está seleccionada en el paso de tiempo t. Las series que no se seleccionan en ningún paso de tiempo no se devuelven. Array(Tuple(key UInt64, steps_mask Array(UInt8)))

Ejemplos

Selección de las 2 series con los valores más altos por paso de tiempo

Query

SET enable_time_series_aggregate_functions = 1;
WITH [(1, [10., 1., NULL]), (2, [20., 2., 2.]), (3, [30., NULL, 1.])]::Array(Tuple(UInt64, Array(Nullable(Float64)))) AS series
SELECT timeSeriesTopKMasks(2, s.1, s.2)
FROM (SELECT arrayJoin(series) AS s);

Response

[(1,[0,1,0]),(2,[1,1,1]),(3,[1,0,1])]