所有配置单元UDF都可以从spark sql访问。您可以在sparksql中重新定义自己的自定义项，并在其中使用配置单元自定义项。sqlcontext.udf.register（（x，percentilevalue）=>{//使用这些参数实现方法}）

你可以用 callUDF 功能：

import org.apache.spark.sql.functions.{callUDF, lit}

val df = Seq((1L, 3L), (2L, 5L), (3L, 4L)).toDF("id", "x")
df.select(callUDF("percentile", $"x", lit(0.5)))

所以中值是这样的函数：

def median(expr: org.apache.spark.sql.Column): org.apache.spark.sql.Column = {
  callUDF("percentile", expr, lit(0.5))
}

df.select(median($"x"))

但不能使用嵌套的udf调用。udf Package 一个函数，该函数对提取的值而不是列进行操作。