Spark преобразовать строку JSON в объект JSON (Java)

Question

Я просматривал примеры преобразования из строки 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"));

Надеюсь, это поможет!