Scala Spark 如何将列数组 [string] 转换为包含 JSON 数组的字符串？

Question

我有一个包含字符串数组的列，我需要将它转换为字符串的 JSON 列表吗？原始值：[a,b,c] 转换值："[\"a\",\"b\",\"c\"]"

Answer 1

您可以组合struct,to_json和get_json_object：

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

val jsonArray = get_json_object(
  to_json(struct($"YOUR_COLUMN".as("data"))),
  "$.data"
)

df.select(jsonArray)