TopOne

✅ Azure Stream Analytics ✅ Fabric Eventstream

Devolve o registo de classificação superior, em que a classificação define a posição de classificação do evento na janela de acordo com a ordem especificada. A ordenação/classificação é baseada 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>

O TopOne utiliza uma expressão escalar opcional que lhe 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 apenas ordenar por bigint, float e datetime é permitido.

OVER ([<PARTIÇÃO POR cláusula<>LIMIT DURATION clause> [<WHEN clause>]]

Determina o grupo de linhas sobre o qual o 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 booleana para as linhas a serem incluídas no grupo. Consulte a cláusula OVER para obter mais detalhes sobre o uso.

Tipos de devolução

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)