scala - Scala 无法在单个 Json 行中获取数据
问题描述
我正在使用 Scala spark streaming，我需要将结果推送到 kafka 主题。我正在使用 .selectExpr("to_json(struct(Column1,Column2,Column3,Column4))as value") .
我得到了结果：
{"Column1":"Value_Column1","Column4":"Value_Column4"}
{"Column1":"Value_Column1","Column2":"Value_Column2"}
{"Column1":"Value_Column1","Column3":"Value_COlumn3"}
我应该如何更改 .selectExpr 或者我需要采取哪些步骤才能获得这样的输出：
{"Column1":"Value_Column1","Column2":"Value_Column2","Column3":"Value_Column3","Column4":"Value_Column4"}
谢谢大家！