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