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之類的操做，

>>阅读原文<<