如何使用列函数scala在to中插入动态开发的字符串查询

import org.apache.spark.sql.functions._
import org.apache.spark.sql.{Column, SparkSession}

// 创建SparkSession
val spark = SparkSession.builder()
  .appName("Dynamic query")
  .master("local")
  .getOrCreate()

// 创建示例DataFrame
val df = spark.range(5).toDF("num")

// 动态生成字符串查询
val dynamicQuery = "num > 2"

// 定义列函数
def dynamicFilter(query: String): Column = {
  expr(query)
}

// 应用列函数并执行查询
val filteredDF = df.filter(dynamicFilter(dynamicQuery))

// 打印过滤后的结果
filteredDF.show()