Spark UDF變長參數的二三事兒

在複雜業務邏輯中，我們經常會用到Spark的UDF，當一個UDF需要傳入多列的內容並進行處理時，UDF的傳參該怎麼做呢? 下面通過變長參數引出，逐一介紹三種可行方法以及一些不可行的嘗試... 引子 變長參數對於我們來說並不陌生，在Java裏我們這麼寫 public void varArgs(String... args)  在Scala裏我們這麼寫 def varArgs(cols: String

>>阅读原文<<