Flink SQL 功能解密系列 —— 流式 TopN 挑戰與實現

TopN 是統計報表和大屏很是常見的功能，主要用來實時計算排行榜。流式的 TopN 不一樣於批處理的 TopN，它的特色是持續的在內存中按照某個統計指標（如出現次數）計算 TopN 排行榜，而後當排行榜發生變化時，發出更新後的排行榜。本文主要講解 Flink SQL 是如何從語法和實現上設計 TopN 的。算法 TopN 語法 全局 TopN 用戶最關心的是如何用 SQL 寫出 TopN 的查詢。

>>阅读原文<<