Spark结构化流：将行转换为json

Question

我正在尝试仅使用 spark API 将 Row 或 DataFrame 转换为 json 字符串。

来自输入Row

+----------------+-----------+
|       someThing|       else|
+----------------+-----------+
|            life|         42|
+----------------+-----------+

与

myDataFrame
.select(struct("*").as("col"))
.select(to_json(col("col")))
.writeStream()
.foreach(new KafkaWriter())
.start()

使用KafkaWriter，即使用row.toString() 我得到了：

[{  
    "someThing":"life",
    "else":42
}]

当我想得到这个时：

{  
    "someThing":"life",
    "else":42
}

（没有[]）

有什么想法吗？

Answer 1

刚刚找到解决方案。使用Row.mkString 而不是Row.toString 解决了我的问题。