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