Verzamelen (Azure Stream Analytics)

Retourneert een matrix met alle recordwaarden uit het venster.

Syntaxis

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

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

Argumenten

Verzamelen maakt gebruik van een optionele scalaire expressie waarmee u een projectie over de verzamelde gebeurtenissen kunt opgeven. Zonder de parameter worden volledige gebeurtenisrecords verzameld.

Retourtypen

Matrix van waarden die worden geprojecteerd door de <scalar_expression> parameter, of matrix van recordwaarden als er geen parameter is opgegeven.

Algemene opmerkingen

De volgorde van de waarden in de geretourneerde matrix is niet gegarandeerd

Voorbeelden

Verzamel alle invoerevenementen binnen een venster van 10 seconden.

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

Verzamel de som van de a velden en b van de invoerevenementen binnen een venster van 10 seconden.

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