如何使用 flink 制作 Map[String, Any] 流答案

【问题标题】：how to make a stream of Map[String, Any] using flink如何使用 flink 制作 Map[String, Any] 流
【发布时间】：2018-05-17 13:33:58
【问题描述】：

假设我们有这个 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": "*******"
    }
  }
}

作为数据流，我想获取另一个包含

的 JSON

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

还有什么方法可以按字段解析文档吗？像 get("Email") 它返回 "FlinkIsDifficult@gmail.com" ??

谢谢:)

【问题讨论】：

标签： json scala apache-flink flink-streaming flink-cep

【解决方案1】：

您可以像在任何其他 Java 或 Scala 程序中一样使用 JSON。请参阅this question 的答案以获取在 Java 中执行此操作的帮助。然后，您可以在 Flink map() 或 flatmap() 函数中应用您选择的任何方法来进行转换。

如果您的 JSON 来自 Kafka，您可能更愿意使用 KafkaJsonTableSource。

【讨论】：