如何使用反射从scala调用spark UDF？

import org.apache.spark.sql.SparkSession

val spark = SparkSession.builder()
  .appName("Spark UDF Reflection")
  .master("local[*]") // 或者指定集群的URL
  .getOrCreate()

def customFunction(input: String): String = {
  // 在这里实现您的自定义函数逻辑
  // 可以使用任何Scala支持的语法和库
  input.toUpperCase()
}

spark.udf.register("myUDF", customFunction _)

import org.apache.spark.sql.functions._

val df = spark.range(10)
df.select(expr("myUDF(id)")).show()