как сделать поток Map [String, Any] используя flink

Question

давайте предположим, что у нас есть этот JSON

{
  "Account Informations": {
    "User Info": {
      "User Name": "Albert Goldstein",
      "Date": "03/27/2015 08:35:11",
      "Location": "New York, USA"
    },
    "User": {
      "Email": "FlinkIsDifficult@gmail.com",
      "Password": "*******"
    }
  }
}

как DataStream, я хочу получить еще один JSON, который содержит

{
        "User": {
          "Email": "FlinkIsDifficult@gmail.com",
          "Password": "*******"
        }
}

также есть ли способ разобрать документ по полю? как get («Email») и возвращает «FlinkIsDifficult@gmail.com» ??

спасибо :)

Answer 1

Вы можете работать с JSON, как и в любой другой программе на Java или Scala.См. Ответы на этот вопрос для помощи в этом на Java.Затем вы можете применить любой подход, выбранный вами, внутри функции Flink map () или flatmap () для преобразования.

Если ваш JSON исходит от Kafka, вы можете использовать KafkaJsonTableSource .