object ProvinceClicks {
  def main(args: Array[String]): Unit = {
    // 原始数据
    val data = Map(
      (('吉林', '玉米'), 2),
      (('吉林', '袜子'), 10),
      (('河南', '山药'), 18),
      (('河南', '鞋'), 3),
      (('河南', '衣服'), 9),
      (('河北', '箱包'), 11),
      (('河北', '鸭梨'), 5),
      (('吉林', '木耳'), 7)
    )

    // 转换数据格式:将 (('省份', '商品'), 点击数) 转换为 (省份, 商品, 点击数)
    val transformedData = data.map { case ((province, product), clicks) => (province, product, clicks) }

    // 按省份分组:将转换后的数据按省份进行分组
    val groupedData = transformedData.groupBy(_._1)

    // 统计每个省份所有商品点击数量的总数:遍历每个省份,计算该省份下所有商品的点击数之和
    val clicksByProvince = groupedData.map { case (province, productList) =>
      (province, productList.map(_._3).sum)
    }

    // 对结果进行升序排序:将统计结果转换为 List,然后按照点击数进行升序排序
    val sortedResult = clicksByProvince.toList.sortBy(_._2)

    // 输出结果
    println(clicksByProvince.map{case (province, clicks) => s"$province -> $clicks"}) // 输出 Map(河南 -> 30, 吉林 -> 19, 河北 -> 16)
    println(sortedResult.map{case (province, clicks) => s"($province,$clicks)"} mkString " ") // 输出 List((河北,16), (吉林,19), (河南,30))
  }
}

代码解释:

  1. 原始数据: 定义一个名为 dataMap,存储每个省份的商品点击次数。
  2. 数据转换:data 中的 (('省份', '商品'), 点击数) 转换为 (省份, 商品, 点击数)。
  3. 按省份分组: 使用 groupBy 函数将 transformedData 按省份分组,得到一个 Map,key 是省份,value 是该省份的所有商品信息。
  4. 统计点击数: 遍历每个省份,计算该省份下所有商品的点击数之和。
  5. 排序: 将统计结果转换为 List,然后使用 sortBy 函数按照点击数进行升序排序。
  6. 输出结果: 输出点击数统计结果和排序后的结果。

输出结果:

Map(河南 -> 30, 吉林 -> 19, 河北 -> 16)
(河北,16) (吉林,19) (河南,30)

代码说明:

  • Map 是 Scala 中用于存储键值对的集合类型。
  • groupBy 函数可以将集合按照指定的条件分组。
  • sortBy 函数可以按照指定的条件对集合进行排序。
  • mkString 函数可以将集合中的元素连接成字符串。

总结:

这段 Scala 代码演示了如何使用 MapgroupBysortBy 函数来统计省份商品点击数并进行排序。它展示了 Scala 中数据处理和排序的灵活性和简洁性。

Scala代码:统计省份商品点击数并排序

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

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