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

UDF： 操作單個數據行，產生單個數據行； UDAF： 操作多個數據行，產生一個數據行。 UDTF： 操作一個數據行，產生多個數據行一個表作爲輸出。 UDF函數 通過spark.udf.register(「funcName」, func) 來進行註冊 使用：select funcName(name) from people 來直接使用 開窗函數 over（）開窗函數： 在使用聚合函數後，會將多行變

>>阅读原文<<