Compartir a través de

TopOne (Azure Stream Analytics)

  • Artículo

Devuelve el registro de clasificación superior, donde rank define la posición de clasificación del evento en la ventana según el orden especificado. La ordenación o clasificación se basa en las columnas de evento y se puede especificar en la cláusula ORDER BY.

Sintaxis

-- 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 toma una expresión escalar opcional que permite especificar una proyección sobre el evento superior. Sin el parámetro , se devuelve el registro de eventos completo.

<column_name>

Especifica el nombre de la columna en el evento de entrada por el que se realizará la ordenación. Tenga en cuenta que solo se permiten los tipos bigint, float y datetime.

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

Determina el grupo de filas sobre el que se aplica TopOne. La cláusula PARTITION BY especifica que las filas con la misma clave de partición se agruparán. La cláusula LIMIT DURATION especifica la cantidad de historial que se incluye en el grupo. La cláusula WHEN opcional especifica una condición booleana para las filas que se van a incluir en el grupo. Consulte la cláusula OVER para obtener más información sobre el uso.

Tipos de valor devuelto

Valor proyectado por el <scalar_expression> parámetro o un valor de registro si no se proporciona ningún parámetro.

Ejemplos

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)