Spark编写UDAF自定义函数

Hive中有UDF与UDAF，Spark中对UDF支持较早，UDAF：User Defined Aggregate Function。用户自定义聚合函数，是直到Spark 1.5.x才引入的最新特性。java UDAF，则能够针对多行输入，进行聚合计算。 sql 编写一个实现平均数的UDAFexpress 一、自定义UDAF，须要extends  org.apache.spark.sql.expr

>>阅读原文<<