如何将DataFrame中的行分组成由分隔符Scala Spark分隔的单行？

import org.apache.spark.sql.functions._

// 创建一个示例DataFrame
val df = Seq(
  ("A", 1),
  ("A", 2),
  ("B", 3),
  ("B", 4),
  ("C", 5)
).toDF("group", "value")

// 使用groupBy和agg函数进行分组和合并
val result = df.groupBy("group")
  .agg(concat_ws(",", collect_list("value")).alias("merged_values"))

result.show()

+-----+-------------+
|group|merged_values|
+-----+-------------+
|    B|          3,4|
|    C|            5|
|    A|          1,2|
+-----+-------------+