Scala 统计不同省份商品点击总数并排序
val data = Map((("吉林", "玉米"), 2),
(("吉林", "袜子"), 10),
(("河南", "山药"), 18),
(("河南", "鞋"), 3),
(("河南", "衣服"), 9),
(("河北", "箱包"), 11),
(("河北", "鸭梨"), 5),
(("吉林", "木耳"), 7))
// 将原始数据格式转换为('省份', '商品', 点击数)的形式
val formattedData = data.map{ case ((province, product), clicks) => (province, product, clicks)}
// 按省份进行分组
val groupedData = formattedData.groupBy(_._1)
// 统计每个省份所有商品点击数量的总数
val result = groupedData.mapValues{ dataList =>
dataList.map(_._3).sum
}.toSeq
// 按点击总数进行升序排序
val sortedResult = result.sortBy(_._2)
// 输出结果
println(sortedResult.toMap)
println(sortedResult)
原文地址: https://www.cveoy.top/t/topic/kwfp 著作权归作者所有。请勿转载和采集!