TopOne

✅ Azure Stream Analytics ✅ Fabric Eventstream

Returnerar den högst rankade posten, där rangordningen definierar händelsens rangordningsposition i fönstret enligt den angivna ordningen. Beställning/rangordning baseras på händelsekolumner och kan anges i ORDER BY-satsen.

Syntax

-- 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>])  

Argumentpunkter

<scalar_expression>

TopOne tar ett valfritt skalärt uttryck som gör att du kan ange en projektion över den översta händelsen. Utan parametern returneras en fullständig händelsepost.

<column_name>

Anger namnet på kolumnen i indatahändelsen som beställningen ska utföras med. Observera att endast sortering efter bigint-, float- och datetime-typer tillåts.

ÖVER ([<PARTITION BY-sats><LIMIT DURATION-sats> [<WHEN-sats>]]

Avgör vilken grupp av rader som TopOne ska tillämpas på. PARTITION BY-satsen anger att raderna med samma partitionsnyckel ska grupperas tillsammans. LIMIT DURATION-satsen anger hur mycket historik som ingår i gruppen. Den valfria WHEN-satsen anger ett booleskt villkor för de rader som ska ingå i gruppen. Mer information om användningen finns i OVER-satsen .

Returtyper

Värde som projiceras av parametern <scalar_expression> eller ett postvärde om ingen parameter anges.

Exempel

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)