Spark 将 JSON 字符串转换为 JSON 对象 (Java)

Question

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

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

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

是否可以在 Java 中做到这一点？

Answer 1

是的，可以在 Java 中执行此操作。但语法略有不同。像这样-

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

希望对您有所帮助！