Spark 2.2.1 SQL UDAF用户自定义函数案例

Spark 2.2.1 SQL UDAF用户自定义函数案例

UDAF：User Defined Aggregation Function，用户自定义的聚合函数，函数本身作用于数据集合，能够在聚合操作的基础上进行自定义操作。例如：UDF会被SparkSQL中的Catalyst封装成为Expression，最终会通过eval方法来计算输入的数据Row。UDAF有大量的Aggregation