spark的UDAF使用

什麼是UDAF? UDAF（User Defined Aggregate Function），即用戶定義的聚合函數，聚合函數和普通函數的區別是什麼呢，普通函數是接受一行輸入產生一個輸出，聚合函數是接受一組（一般是多行）輸入然後產生一個輸出，即將一組的值想辦法聚合一下。類似於sum操作,spark的udf使用看這裏 直接看下面的demo,計算1-10的平均值,代碼也比較簡單 package spar

>>阅读原文<<