在Scala Spark中使用与DataFrame相关的过滤函数中的定义值

import org.apache.spark.sql.SparkSession

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

    import spark.implicits._

    // 创建一个DataFrame
    val data = Seq(
      ("Alice", 25),
      ("Bob", 30),
      ("Charlie", 35)
    ).toDF("name", "age")

    // 定义值为常量
    val filterValue = 30

    // 使用过滤函数进行筛选
    val filteredData = data.filter($"age" > filterValue)

    // 显示筛选结果
    filteredData.show()
  }
}