Compartilhar via

TopOne (Azure Stream Analytics)

  • Artigo

Retorna o registro de classificação superior, em que a classificação define a posição de classificação do evento na janela de acordo com a ordenação especificada. Ordenação/classificação baseia-se em colunas de eventos e pode ser especificada na cláusula ORDER BY.

Sintaxe

-- Aggregate Function Syntax
TopOne( [ <scalar_expression> ] ) OVER (ORDER BY (<column name> [ASC |DESC])+)  

-- Analytic Function Syntax
TopOne( [ <scalar_expression> ] ) OVER ([<PARTITION BY clause>] ORDER BY (<column name> [ASC |DESC])+ <LIMIT DURATION clause> [<WHEN clause>])

Argumentos

<scalar_expression>

TopOne usa uma expressão escalar opcional que permite especificar uma projeção sobre o evento superior. Sem o parâmetro , o registro de evento completo é retornado.

<column_name>

Especifica o nome da coluna no evento de entrada pelo qual a ordenação será feita. Observe que somente a ordenação por tipos bigint, float e datetime são permitidas.

OVER ([<Cláusula LIMIT DURATION> da cláusula><PARTITION BY [<cláusula> WHEN]]

Determina o grupo de linhas sobre as quais TopOne é aplicado. A cláusula PARTITION BY especifica que as linhas com a mesma chave de partição serão agrupadas. A cláusula LIMIT DURATION especifica quanto histórico está incluído no grupo. A cláusula WHEN opcional especifica uma condição booliana para as linhas a serem incluídas no grupo. Consulte a cláusula OVER para obter mais detalhes sobre o uso.

Tipos de retorno

Valor projetado pelo <scalar_expression> parâmetro ou um valor de registro se nenhum parâmetro for fornecido.

Exemplos

SELECT   
    TopOne() OVER (ORDER BY value DESC) as topEvent  
FROM input  
GROUP BY Tumbling(second, 10)  
  

SELECT   
    TopOne(x * y) OVER (ORDER BY value DESC) as topEvent  
FROM input  
GROUP BY Tumbling(second, 10)