java—如何向ApacheFlink表添加新行

wkftcu5l  于 2021-06-21  发布在  Flink
关注(0)|答案(1)|浏览(293)

是否可以向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分享答案。

vlurs2pr

vlurs2pr1#

听起来您想要的是在 StreamTableEnvironment . 动态表的关键是它可以不断更新。
对于FlinkSQL的可靠介绍,我推荐https://www.youtube.com/watch?v=unckwip_614.

相关问题