是否可以向flink表中添加新记录/行?例如,我有下表配置:
ExecutionEnvironment env = TableEnvironmentLoader.getExecutionEnvironment();
BatchTableEnvironment tableEnv = TableEnvironmentLoader.getBatchTableEnvironment();
Table subscribers = tableEnv.fromDataset(subscribers, "firstName, lastName, age");
tableEnv.registerTable("subscribers", subscribers);
现在让我们假设在稍后的一点上,我有一个额外的数据集或tuple3,其中包含相同的字段;名字,姓氏,年龄。如何将其添加到现有的flink订阅服务器表中?使用动态表或其他注册表的方法(例如:tableenv.registertemporaryview(“subscribers”,subscribers))能解决这个问题吗?我无法将另一条记录添加到此表中而不删除它并重新创建它,这太昂贵了。
请用java分享答案。
1条答案
按热度按时间vlurs2pr1#
听起来您想要的是在
StreamTableEnvironment
. 动态表的关键是它可以不断更新。对于FlinkSQL的可靠介绍,我推荐https://www.youtube.com/watch?v=unckwip_614.