如何使用flink生成map[string,any]流

dkqlctbz  于 2021-06-24  发布在  Flink
关注(0)|答案(1)|浏览(321)

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

作为一个数据流,我想得到另一个包含

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

还有什么方法可以按字段解析文档吗?比如get(“email”),它会返回“flinkisdifficult@gmail.com" ??
谢谢:)

rvpgvaaj

rvpgvaaj1#

您可以像在任何其他java或scala程序中一样使用json。请参阅此问题的答案,以获取在java中执行此操作的帮助。然后可以在flink map()或flatmap()函数中应用您选择的任何方法来进行转换。
如果您的json来自kafka,您可能更愿意使用kafkajsontablesource。

相关问题