TopOne (Azure Stream Analytics)
En üst sıradaki kaydı döndürür; burada rank, belirtilen sıralamaya göre olayın penceredeki derecelendirme konumunu tanımlar. Sıralama/sıralama olay sütunlarını temel alır ve ORDER BY yan tümcesinde belirtilebilir.
Söz dizimi
-- 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>])
Bağımsız değişkenler
<Scalar_expression>
TopOne, en üstteki olay üzerinde bir projeksiyon belirtmenize olanak tanıyan isteğe bağlı bir skaler ifade alır. parametresi olmadan tam olay kaydı döndürülür.
<Column_name>
Sıralamanın gerçekleştirileceği giriş olayında sütunun adını belirtir. Yalnızca bigint, float ve datetime türlerine göre sıralamaya izin verilir.
OVER ([<PARTITION BY yan tümcesi><LIMIT DURATION yan tümcesi> [<WHEN yan tümcesi>]]
TopOne'un uygulandığı satır grubunu belirler. PARTITION BY yan tümcesi, aynı bölüm anahtarına sahip satırların birlikte gruplandırılacağını belirtir. LIMIT DURATION yan tümcesi, gruba ne kadar geçmişin dahil olduğunu belirtir. İsteğe bağlı WHEN yan tümcesi, gruba eklenecek satırların boole koşulunu belirtir. Kullanım hakkında daha fazla bilgi için over yan tümcesine bakın.
Dönüş Türleri
Parametresi tarafından öngörülen değer veya parametre sağlanmazsa <scalar_expression>
bir kayıt değeri.
Örnekler
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)