0

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

4

1 回答 1

0

听起来您想要的StreamTableEnvironment. 动态表的全部意义在于它可以不断更新。

对于 Flink SQL 的深入介绍,我推荐https://www.youtube.com/watch?v=UnCkwIp_614

于 2020-06-15T08:11:21.847 回答