SparkSQL 用戶自定義函數（UDF、UDAF、開窗）

UDF函數sql 經過spark.udf.register("funcName", func) 來進行註冊 express 使用：select funcName(name) from people 來直接使用apache UDAF函數json 弱類型ide 須要繼承UserDefineAggregateFunction並實現相關方法函數使用：一樣是註冊一個udf函數 import org.apac

>>阅读原文<<