timeSeriesLimitKMasks

​

timeSeriesLimitKMasks

timeSeriesLimitKMasks(k, key, sampling_key, values)

• k — عدد السلاسل المطلوب اختيارها عند كل خطوة زمنية، إما قيمة واحدة لجميع الخطوات الزمنية أو مصفوفة تحتوي على قيمة لكل خطوة زمنية. يجب أن تكون القيمة نفسها لجميع الصفوف. UInt* أو Array(UInt*)
• key — معرّف السلسلة الزمنية. UInt64
• sampling_key — قيمة تجزئة لكل سلسلة تحدد ترتيب الاختيار، مثل timeSeriesGroupToSamplingKey(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], 300), (2, [20., 2., 2.], 100), (3, [30., NULL, 1.], 200)]::Array(Tuple(UInt64, Array(Nullable(Float64)), UInt64)) AS series
SELECT timeSeriesLimitKMasks(2, s.1, s.3, s.2)
FROM (SELECT arrayJoin(series) AS s);

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