scala - Scala更新映射列中键的值

Question

我需要更新地图列中键的值（additional_values）。假设我在数据（sourceData）中有 2 列。account_num 和附加值。additional_values 有许多键/值对。

键值对之一是“id”：“123”。我需要在 account_num 上加入不同的数据集（refData）并获取与 account_num 关联的 id 并在 sourceData 中更新它。所有其他键/值对应保持不变。

我加入了数据集并创建了一个名为 id_new 的新列。我尝试使用更新的方法，但没有运气。

val newOutputDF = outputDF .select(col("additional_values")).updated(col("id"), col("id_new"))

我怎样才能做到这一点？

标签： scalaapache-sparkapache-spark-sqluser-defined-functions