Поделиться через

Collect (Azure Stream Analytics)

  • Статья

Возвращает массив со всеми значениями записей из окна.

Синтаксис

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

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

Аргументы

Collect принимает необязательное скалярное выражение, которое позволяет указать проекцию по собранным событиям. Без параметра собираются полные записи событий.

Типы возвращаемых данных

Массив значений, проецируемых параметром <scalar_expression> , или массив значений записей, если параметр не указан.

Общие замечания

Порядок значений в возвращаемом массиве не гарантируется

Примеры

Сбор всех входных событий в течение 10-секундного окна.

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

Соберите суммы a полей и b входных событий в течение 10-секундного окна.

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