[大數據]連載No16之 SparkSql函數+SparkStreaming算子

本次總結圖如下 SparkSql可以自定義函數、聚合函數、開窗函數 作用說明：自定義一個函數，並且註冊本身，這樣就能在SQL語句中使用  使用方式sqlContext.udf().register(函數名，函數(輸入，輸出),返回類型)） 代碼 public static void main(String[] args) { SparkConf conf = new SparkConf()

>>阅读原文<<