sparkSQL中UDF的使用

在spark中使用sql时一些功能须要自定义方法实现,这时候就可使用UDF功能来实现python 多参数支持 UDF不支持参数*的方式输入多个参数,例如String*,不过可使用array来解决这个问题。web 定义udf方法,此处功能是将多个字段合并为一个字段sql def allInOne(seq: Seq[Any], sep: String): String = seq.mkString(s
相关文章
相关标签/搜索