timeSeriesBottomKMasks

각 그리드 간격마다 값이 가장 작은 k개의 시계열을 선택합니다.

​

timeSeriesBottomKMasks

도입 버전: v26.8.0

시간 그리드의 각 시간 간격마다 값이 가장 작은 k개의 시계열을 선택합니다.

각 입력 행은 하나의 시계열입니다. key는 시계열을 식별하고 values에는 공통 시간 그리드에 맞춰 정렬된 값이 담기므로, 모든 행의 values 배열은 크기가 같아야 합니다. 각 시간 간격마다 해당 시점에서 NULL이 아닌 값이 가장 작은 k개의 시계열이 선택됩니다(NaN은 다른 어떤 값보다 큰 것으로 간주됩니다). 값이 같으면 key가 더 작은 시계열이 우선 선택됩니다.

이 함수는 PromQL의 bottomk() 집계 연산자를 구현하며, 시간 간격마다 크기가 k로 제한된 힙을 하나만 유지하므로 상태 크기가 집계 대상 시계열의 수와 무관합니다.

이 함수는 비공개 프리뷰 단계이며, enable_time_series_aggregate_functions = 1로 설정하여 활성화할 수 있습니다.

구문

timeSeriesBottomKMasks(k, key, values)

인수

• k — 각 시간 간격마다 선택할 시계열(series)의 개수입니다. 모든 시간 간격에 공통으로 적용되는 단일 값이거나, 시간 간격마다 값이 하나씩 있는 배열입니다. 모든 행에서 동일해야 합니다. UInt* 또는 Array(UInt*)
• key — 시계열의 식별자입니다. UInt64
• values — 시간 그리드(time grid)에 맞춰 정렬된 시계열 값으로, 시간 간격마다 원소가 하나씩 있습니다. Array(Nullable(Float32)) 또는 Array(Nullable(Float64)) 또는 Array(Float32) 또는 Array(Float64)

반환 값

선택된 시계열을 key 오름차순으로 반환하며, 각 시계열에는 간격별 마스크가 함께 포함됩니다. 시계열이 시간 간격 t에서 선택되면 steps_mask[t] = 1입니다. 어느 시간 간격에서도 선택되지 않은 시계열은 반환되지 않습니다. Array(Tuple(key UInt64, steps_mask Array(UInt8)))

예시

시간 간격마다 가장 작은 시계열 2개 선택하기

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 timeSeriesBottomKMasks(2, s.1, s.2)
FROM (SELECT arrayJoin(series) AS s);

Response

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