//定义数据格式转换函数 def transData(data: ((String, String), Int)): (String, String, Int) = { val (province, product) = data._1 val count = data._2 (province, product, count) }

//定义数据 val data = Map(('吉林','玉米') -> 2, ('吉林','袜子') -> 10, ('河南','山药') -> 18, ('河南','鞋') -> 3, ('河南','衣服') -> 9, ('河北','箱包') -> 11, ('河北','鸭梨') -> 5, ('吉林','木耳') -> 7 )

//将数据格式转换,并按省份进行分组 val groupData = data.map(transData).groupBy(_._1)

//统计每个省份所有商品点击数量的总数,并按升序排序 val result = groupData.mapValues(.map(.3).sum).toList.sortBy(._2)

//输出结果 println(result.toMap) println(result)

Scala 统计不同省份商品点击总数并排序

原文地址: https://www.cveoy.top/t/topic/kwjS 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录