使用flink實現一個topN的程序

　topN功能是一個非常常見的功能，比如查看最近幾分鐘的閱讀最高數，購買最高數。 　　flink實現topN的功能也非常方便，下面就開始構建一個flink topN的程序。 　　還是像上篇博客一樣，從kafka讀取數據，然後進行計算和數據轉換，最後sink到mysql中。 　　假設有個需求，實現一個統計每5分鐘最高購買數的商品。 　　使用maven創建一個工程，具體步驟可以參考上邊博文。然後創建一

>>阅读原文<<