在使用scala访问Int列的每一行时需要帮助

import org.apache.spark.sql.SparkSession

val spark = SparkSession.builder()
  .appName("Scala Accessing Int Column")
  .master("local")
  .getOrCreate()

val data = spark.read
  .format("csv")
  .option("header", "true")
  .load("path/to/your/file.csv")

import org.apache.spark.sql.functions.col

val intData = data.select(col("intColumn").cast("Int"))

// 过滤大于10的值
val filteredData = intData.filter(col("intColumn") > 10)

// 计算平均值
val avgValue = intData.agg(avg(col("intColumn")))

// 按值进行排序
val sortedData = intData.orderBy(col("intColumn").asc)

intData.foreach(row => {
  val intValue = row.getInt(0) // 获取Int列的值
  // 进行其他操作
})