如何将spark数据框中的WrappedArray列转换为字符串？

WrappedArray不是一个Array(普通的旧Java Array不是一个natve Scala集合).您可以将签名更改为:

import scala.collection.mutable.WrappedArray

(arrayCol: WrappedArray[String]) => arrayCol.mkString(",")

或使用其中一种超类型Seq:

(arrayCol: Seq[String]) => arrayCol.mkString(",")

在最近的Spark版本中,您可以使用concat_ws:

import org.apache.spark.sql.functions.concat_ws

df.select(concat_ws(",", $"arrayCol"))