timeSeriesTopKMasks

​

timeSeriesTopKMasks

timeSeriesTopKMasks(k, key, values)

• k — Количество серий, выбираемых на каждом временном шаге: либо одно значение для всех шагов, либо массив с отдельным значением для каждого шага. Должно быть одинаковым для всех строк. UInt* или Array(UInt*)
• key — Идентификатор временной серии. UInt64
• values — Значения временной серии, выровненные по временной сетке, — по одному элементу на каждый временной шаг. Array(Nullable(Float32)) или Array(Nullable(Float64)) или Array(Float32) или Array(Float64)

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);

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