Spark 将 JSON 字符串转换为 JSON 对象（Java）答案

【问题标题】：Spark convert JSON string to JSON object (Java)Spark 将 JSON 字符串转换为 JSON 对象（Java）
【发布时间】：2018-04-30 16:56:33
【问题描述】：

我一直在查看从 Kafka 接收到的 JSON 字符串到 JSON 对象的转换示例。我只找到了对我没有太大帮助的 Scala 示例。

然而在 Scala 中它看起来像这样：

val schema = new StructType().add("b", IntegerType)
events.select(from_json('a, schema) as 'c)

在 Java 中可以做到这一点吗？

【问题讨论】：

【解决方案1】：

是的，在 Java 中可以做到这一点。但语法略有不同。像这样-

StructType schema = new StructType().add("b", DataTypes.IntegerType);
events.select(from_json(col("a"), schema).as("c"));

希望对你有帮助！

【讨论】：