Coletar (Azure Stream Analytics)

Artigo
08/02/2024

Retorna uma matriz com todos os valores de registro da janela.

Sintaxe

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

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

Argumentos

Collect usa uma expressão escalar opcional que permite especificar uma projeção sobre os eventos coletados. Sem o parâmetro , os registros de eventos completos são coletados.

Tipos de retorno

Matriz de valores projetados pelo <scalar_expression> parâmetro ou matriz de valores de registro se nenhum parâmetro for fornecido.

Comentários gerais

A ordenação dos valores dentro da matriz retornada não é garantida

Exemplos

Colete todos os eventos de entrada em uma janela de 10 segundos.

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

Colete as somas dos a campos e b dos eventos de entrada em uma janela de 10 segundos.

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

Compartilhar via