Dela via


Samla

✅ Azure Stream Analytics ✅ Fabric Eventstream

Returnerar en matris med alla postvärden från fönstret.

Syntax

-- Aggregate Function Syntax
Collect ( [ <scalar_expression> ] )

-- Analytic Function Syntax
Collect ( [ <scalar_expression> ] ) OVER ([<PARTITION BY clause>] <LIMIT DURATION clause> [<WHEN clause>])

Argumentpunkter

Collect tar ett valfritt skalärt uttryck som gör att du kan ange en projektion över de insamlade händelserna. Utan parametern samlas fullständiga händelseposter in.

Returtyper

Matris med värden som projiceras av parametern eller matrisen <scalar_expression> med postvärden om ingen parameter anges.

Allmänna kommentarer

Ordningen på värdena i den returnerade matrisen garanteras inte

Exempel

Samla in alla indatahändelser inom ett fönster på 10 sekunder.

SELECT Collect() AS allEvents 
FROM Input 
GROUP BY Tumbling(second, 10) 

Samla in summorna för fälten a och b för indatahändelserna i ett 10 sekunders fönster.

SELECT Collect(a + b) AS allab 
FROM Input 
GROUP BY Tumbling(second,10)