Spark 計算 - 實現分組求 TopN

問題抽象 找出分組內數據的 TopN。java 問題實例 找出每一個城市(province)應用點擊數(click)排前5的人(name)。這裏假定省內每一個人的點擊數以及計算好了。web 思路 思路: 這裏的名字只是附屬屬性，求每一個省份最高的5個點擊數便可。首先按照省份分組，在組內聚合求 top 5參考 top() 算子的實現方法，使用一個有固定長度（這裏即5）的優先隊列，每一個組內迭代將元素

>>阅读原文<<