sparkSql中udf的應用

在sparkSql中部分功能須要定製化，須要用到udf。sql 在sql中，我須要根據三個字段獲得一個數組，後續過程當中利用這個數組進行計算，下面是scala的實現過程：數組 sparkSession.udf.register("fvptopic", (op:String,why:String,ext4:String)=> (op match { case "1"|"2"|

>>阅读原文<<