Adatgyűjtés (Azure Stream Analytics)
Az ablak összes rekordértékét tartalmazó tömböt ad vissza.
Szintaxis
-- Aggregate Function Syntax
Collect ( [ <scalar_expression> ] )
-- Analytic Function Syntax
Collect ( [ <scalar_expression> ] ) OVER ([<PARTITION BY clause>] <LIMIT DURATION clause> [<WHEN clause>])
Argumentumok
A Collect egy opcionális skaláris kifejezést vesz igénybe, amely lehetővé teszi, hogy kivetítőt adjon meg az összegyűjtött eseményekre. A paraméter nélkül a rendszer teljes eseményrekordokat gyűjt.
Visszatérési típusok
A paraméter által <scalar_expression>
vetített értékek tömbje vagy rekordértékek tömbje, ha nincs megadva paraméter.
Általános megjegyzések
A visszaadott tömbben lévő értékek sorrendje nem garantált
Példák
Gyűjtse össze az összes bemeneti eseményt egy 10 másodperces ablakban.
SELECT Collect() AS allEvents
FROM Input
GROUP BY Tumbling(second, 10)
Gyűjtse össze a a
bemeneti események és b
mezők összegét egy 10 másodperces ablakban.
SELECT Collect(a + b) AS allab
FROM Input
GROUP BY Tumbling(second,10)