// 导入 Spark 相关库
import org.apache.spark.{SparkConf, SparkContext}

object SparkInitializationExample {
  def main(args: Array[String]): Unit = {
    // 设置 Spark 应用程序的配置
    val conf = new SparkConf()
      .setAppName("Spark Initialization Example")
      .setMaster("local[*]")  // 在本地模式运行，使用所有可用的 CPU 核心

    // 创建 SparkContext，它是 Spark 应用程序的入口点
    val sc = new SparkContext(conf)

    try {
      // 创建一个包含 1 到 10 的整数的 RDD
      val data = 1 to 10
      val rdd = sc.parallelize(data)

      // 执行一些简单的转换和动作操作
      val doubledRDD = rdd.map(x => x * 2)
      val sum = doubledRDD.reduce((a, b) => a + b)

      // 打印结果
      println(s"Original RDD: ${rdd.collect().mkString(", ")}")
      println(s"Doubled RDD: ${doubledRDD.collect().mkString(", ")}")
      println(s"Sum of Doubled RDD: $sum")
    } finally {
      // 关闭 SparkContext
      sc.stop()
    }
  }
}