SparkSQL项目实战
2021-12-28 本文已影响0人
抬头挺胸才算活着
-
需求
-
SQL语句
1、join得到城市和产品名称
2、group by得到一个地区的总的点击次数
3、取前三可以先用开窗函数排序后where只保留前三
-
UDAF
剩下城市备注这个是最难的,我们可以在第二步group by的时候使用UDAF,每次聚合使用map保留每个城市聚合的次数,最后再生成字符串。
需求
SQL语句
1、join得到城市和产品名称
UDAF
剩下城市备注这个是最难的,我们可以在第二步group by的时候使用UDAF,每次聚合使用map保留每个城市聚合的次数,最后再生成字符串。