Scala Spark -如何迭代Dataframe中的字段

import org.apache.spark.sql.SparkSession

object DataFrameIteration {
  def main(args: Array[String]): Unit = {
    val spark = SparkSession.builder()
      .appName("DataFrameIteration")
      .master("local")
      .getOrCreate()

    import spark.implicits._

    // 创建一个示例Dataframe
    val data = Seq(
      ("Alice", 25),
      ("Bob", 30),
      ("Charlie", 35)
    )
    val df = data.toDF("Name", "Age")

    // 使用foreach函数迭代Dataframe中的字段
    df.foreach(row => {
      val name = row.getAs[String]("Name")
      val age = row.getAs[Int]("Age")
      println(s"Name: $name, Age: $age")
    })

    // 使用map函数迭代Dataframe中的字段
    val result = df.map(row => {
      val name = row.getAs[String]("Name")
      val age = row.getAs[Int]("Age")
      s"Name: $name, Age: $age"
    })
    result.show()

    spark.stop()
  }
}