Spark (Scala)将具有重复项的列表转换为(list_entry，count)的映射

import org.apache.spark.{SparkConf, SparkContext}

object SparkListCount {
  def main(args: Array[String]): Unit = {
    // 创建Spark配置
    val conf = new SparkConf().setAppName("SparkListCount").setMaster("local")
    // 创建Spark上下文
    val sc = new SparkContext(conf)

    // 输入数据
    val inputList = List("apple", "banana", "apple", "orange", "banana", "apple")
    // 将输入数据转换为RDD
    val inputRDD = sc.parallelize(inputList)

    // 对RDD进行转换和计数
    val countRDD = inputRDD.map(entry => (entry, 1)).reduceByKey(_ + _)

    // 输出结果
    countRDD.collect().foreach(println)

    // 停止Spark上下文
    sc.stop()
  }
}