SparkSQL UDF 實現數據轉換功能

項目中需要實現一個udf完成一個數據轉換的功能，網上的例子都是比較簡單的那種，比如字符串變換或者字符串長度統計這種簡單功能。 我這個稍微複雜一些，需要傳入數據字典，字段要和數據字典中的字段進行比對，然後返回數據字典中的一個結果字段。 這個很簡單的功能花費了我不少的時間，主要是sparksql 的udf 傳入list這種複雜的數據的時候，解釋會報錯。 這導致我廢了很長時間來解決這個問題。後來發現其實

>>阅读原文<<