Compartir a través de


Recopilación (Azure Stream Analytics)

Devuelve una matriz con todos los valores de registro de la ventana.

Sintaxis

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

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

Argumentos

Collect toma una expresión escalar opcional que permite especificar una proyección sobre los eventos recopilados. Sin el parámetro , se recopilan registros de eventos completos.

Tipos de valor devuelto

Matriz de valores proyectados por el <scalar_expression> parámetro o matriz de valores de registro si no se proporciona ningún parámetro.

Notas generales

No se garantiza el orden de los valores dentro de la matriz devuelta.

Ejemplos

Recopile todos los eventos de entrada en una ventana de 10 segundos.

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

Recopile las sumas de los a campos y b de los eventos de entrada dentro de una ventana de 10 segundos.

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