Collect (Azure Stream Analytics)

Artikel
08/02/2024

Gibt ein Array mit allen Datensatzwerten aus dem Fenster zurück.

Syntax

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

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

Argumente

Collect verwendet einen optionalen skalaren Ausdruck, mit dem Sie eine Projektion über die gesammelten Ereignisse angeben können. Ohne den Parameter werden vollständige Ereignisdatensätze gesammelt.

Rückgabetypen

Array von Werten, die <scalar_expression> vom Parameter projiziert werden, oder Array von Datensatzwerten, wenn kein Parameter angegeben wird.

Allgemeine Hinweise

Die Reihenfolge der Werte innerhalb des zurückgegebenen Arrays ist nicht garantiert.

Beispiele

Erfassen Sie alle Eingabeereignisse innerhalb eines 10-Sekunden-Fensters.

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

Sammeln Sie die Summen der a Felder und b der Eingabeereignisse innerhalb eines 10-Sekunden-Fensters.

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

Freigeben über