Udostępnij za pośrednictwem

Collect (Azure Stream Analytics)

  • Artykuł

Zwraca tablicę ze wszystkimi wartościami rekordów z okna.

Składnia

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

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

Argumenty

Funkcja Collect przyjmuje opcjonalne wyrażenie skalarne, które umożliwia określenie projekcji dla zebranych zdarzeń. Bez parametru zbierane są pełne rekordy zdarzeń.

Typy zwracane

Tablica wartości przewidywanych przez <scalar_expression> parametr lub tablicę wartości rekordów, jeśli nie podano parametru.

Uwagi ogólne

Porządkowanie wartości w zwracanej tablicy nie jest gwarantowane

Przykłady

Zbierz wszystkie zdarzenia wejściowe w 10-sekundowym oknie.

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

Zbierz sumy a pól i b zdarzeń wejściowych w 10 sekundowym oknie.

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