假设我们有这个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" ??
谢谢:)
1条答案
按热度按时间rvpgvaaj1#
您可以像在任何其他java或scala程序中一样使用json。请参阅此问题的答案,以获取在java中执行此操作的帮助。然后可以在flink map()或flatmap()函数中应用您选择的任何方法来进行转换。
如果您的json来自kafka,您可能更愿意使用kafkajsontablesource。