JSONObject到Row的转换，那你完全可以把这个套在DataStream.map中，把它转换成Flink
table支持的结构化类型。
Best,
Jingsong Lee
--
From:aven.wu
Send Time:2019年12月31日(星期二) 14:09
To:user-zh@flink.apache.org
Subject:回复: StreamTableEnvironment.registerDatastream()
开放用户自定义的
你好！
“把 JSONObject类型定义成object类型” 可以解决在确定字段和类型的情况下并且需要编码到程序中。
如果能开放这部分的能力，可以不通过编码（新增POJO）的方式来完成一个Datastream 到 stream 的table注册。
best wish
发送自 Windows 10 版邮件应用
发件人: Terry Wang
发送时间: 2019年12月30日 12:37
收件人: user-zh@flink.apache.org
主题: Re: StreamTableEnvironment.registerDatastream()
