Recolher (Azure Stream Analytics)

Artigo
08/02/2024

Devolve uma matriz com todos os valores de registo 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 utiliza uma expressão escalar opcional que lhe permite especificar uma projeção sobre os eventos recolhidos. Sem o parâmetro, são recolhidos registos de eventos completos.

Tipos de Devolução

Matriz de valores projetados pelo <scalar_expression> parâmetro ou matriz de valores de registo se não for fornecido nenhum parâmetro.

Observações Gerais

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

Exemplos

Recolha todos os eventos de entrada numa janela de 10 segundos.

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

Recolha as somas dos a campos e b dos eventos de entrada numa janela de 10 segundos.

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

Partilhar via