Spark-Core结合商品订单案例理解RDD中算子的用法_var groupedavg:rdd[string ,double] = numbers-CSDN博客

网站介绍:文章浏览阅读251次。1.需求:在给定的订单数据,根据订单的分类ID进行聚合,然后按照订单分类名称,统计出某一天商品各个分类的成交金额,然后在结合商品分类表匹配上对应的商品分类字段,然后将计算结果保存到mysql中,要求结果如图所示:2.数据样例{"cid": 1, "money": 600.0, "longitude":116.397128,"latitude":39.916527,"oid":"o123", }"oid":"o112", "cid": 3, "money": 200.0, "longit_var groupedavg:rdd[string ,double] = numbers