pyspark.sql.UDFRegistration

class pyspark.sql. UDF注册 ( sparkSession : SparkSession ) [source]

用户定义函数注册的封装。可以通过 spark.udf sqlContext.udf 访问此实例。

在版本 1.3.1 中新推出。

方法

register (名称, 函数[, 返回类型])

将Python函数(包括lambda函数)或用户定义的函数注册为SQL函数。

registerJavaFunction (名称, javaClassName[, …])

将Java用户定义函数注册为SQL函数。

registerJavaUDAF (名称,java类名)

将一个用户定义的Java聚合函数注册为SQL函数。