sparkSQL中UDF的使用

在spark中使用sql時一些功能須要自定義方法實現,這時候就可使用UDF功能來實現python 多參數支持 UDF不支持參數*的方式輸入多個參數,例如String*,不過可使用array來解決這個問題。web 定義udf方法,此處功能是將多個字段合併爲一個字段sql def allInOne(seq: Seq[Any], sep: String): String = seq.mkString(s
相關文章
相關標籤/搜索