sparkSql中udf的应用

在sparkSql中部分功能须要定制化，须要用到udf。sql 在sql中，我须要根据三个字段获得一个数组，后续过程当中利用这个数组进行计算，下面是scala的实现过程：数组 sparkSession.udf.register("fvptopic", (op:String,why:String,ext4:String)=> (op match { case "1"|"2"|

>>阅读原文<<