SparkSQL UDF 实现数据转换功能

项目中需要实现一个udf完成一个数据转换的功能，网上的例子都是比较简单的那种，比如字符串变换或者字符串长度统计这种简单功能。 我这个稍微复杂一些，需要传入数据字典，字段要和数据字典中的字段进行比对，然后返回数据字典中的一个结果字段。 这个很简单的功能花费了我不少的时间，主要是sparksql 的udf 传入list这种复杂的数据的时候，解释会报错。 这导致我废了很长时间来解决这个问题。后来发现其实

>>阅读原文<<