如何根据其他列在火花中添加地图列？

Question

我有这张桌子：

|Name|Val|
|----|---|
|Bob |1  |
|Marl|3  |

我想将其转换为具有单个元素的地图，如下所示：

|Name|Val|MapVal|
|----|---|------|
|Bob |1  |(0->1)|
|Marl|3  |(0->3)|

知道如何在 Scala 中做到这一点吗？我在withColumn声明中找不到任何方法来构建地图...

Answer 1

找到了 - 只需要包含隐式 sql：

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

然后使用map函数： df.withColumn("MapVal", map(lit(0), col("Val")))