✅ Azure 串流分析 ✅ 網狀架構事件串流
傳回數位,其中包含視窗的所有記錄值。
語法
-- Aggregate Function Syntax
Collect ( [ <scalar_expression> ] )
-- Analytic Function Syntax
Collect ( [ <scalar_expression> ] ) OVER ([<PARTITION BY clause>] <LIMIT DURATION clause> [<WHEN clause>])
論點
Collect 會採用選擇性純量表達式,可讓您指定所收集事件的投影。 如果沒有 參數,則會收集完整的事件記錄。
傳回型別
參數 <scalar_expression> 投影的值陣列,如果沒有提供任何參數,則為記錄值的陣列。
一般備註
不保證傳回陣列中值的排序
範例
收集 10 秒視窗中的所有輸入事件。
SELECT Collect() AS allEvents
FROM Input
GROUP BY Tumbling(second, 10)
收集輸入事件在 10 秒範圍內和欄位的總和ab。
SELECT Collect(a + b) AS allab
FROM Input
GROUP BY Tumbling(second,10)