Sdílet prostřednictvím


Collect (Azure Stream Analytics)

Vrátí pole se všemi hodnotami záznamu z okna.

Syntaxe

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

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

Argumenty

Funkce Collect přebírá volitelný skalární výraz, který umožňuje určit projekci shromážděných událostí. Bez parametru se shromažďují úplné záznamy událostí.

Návratové typy

Pole hodnot promítaných parametrem <scalar_expression> nebo pole hodnot záznamů, pokud není parametr zadaný.

Obecné poznámky

Řazení hodnot v rámci vráceného pole není zaručeno.

Příklady

Shromážděte všechny vstupní události během 10sekundového okna.

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

Shromážděte součty a polí a b vstupních událostí během 10sekundového okna.

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