SparkSQL 用户自定义函数（UDF、UDAF、开窗）

UDF： 操作单个数据行，产生单个数据行； UDAF： 操作多个数据行，产生一个数据行。 UDTF： 操作一个数据行，产生多个数据行一个表作为输出。 UDF函数 通过spark.udf.register(“funcName”, func) 来进行注册 使用：select funcName(name) from people 来直接使用 开窗函数 over（）开窗函数： 在使用聚合函数后，会将多行变

>>阅读原文<<