Scala 实现省份商品点击数量统计与排序
object ClickCount { def main(args: Array[String]): Unit = { val data = Map(('吉林','玉米') -> 2, ('吉林','袜子') -> 10, ('河南','山药') -> 18, ('河南','鞋') -> 3, ('河南','衣服') -> 9, ('河北','箱包') -> 11, ('河北','鸭梨') -> 5, ('吉林','木耳') -> 7 )
// 转换数据格式
val newData = data.map{case (province, count) => (province, (count))}
// 按省份进行分组
val groupData = newData.groupBy(_._1)
// 统计每个省份所有商品点击数量的总数
val countData = groupData.map{case (province, tupleList) =>
val count = tupleList.foldLeft(0)(_ + _._2)
(province, count)
}
// 对统计结果进行升序排序
val sortedData = countData.toList.sortBy(_._2)
println(countData)
println(sortedData)
} }
原文地址: https://www.cveoy.top/t/topic/kwhp 著作权归作者所有。请勿转载和采集!