SparkSQL中自定義聚合(UDAF)函數

在學習Hive的時候我們已經瞭解到當內置函數無法滿足你的業務處理需要時，此時就可以考慮使用用戶自定義函數(UDF:user defined function) 用戶自定義函數類別分爲以下三種： 1).UDF：輸入一行，返回一個結果(一對一)，在上篇案例 使用SparkSQL實現根據ip地址計算歸屬地二 中實現的自定義函數就是UDF，輸入一個十進制的ip地址，返回一個省份 2).UDTF：輸入一行，

>>阅读原文<<