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函数。