是否可以向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”,订户))是否可以解决此问题?我无法在不删除该表并再次创建的情况下向该表添加另一条记录,这太昂贵了。
请在Java中共享答案。
听起来您想要在dynamic table中使用StreamTableEnvironment
。动态表的全部意义在于它可以不断更新。
有关Flink SQL的详细介绍,我建议https://www.youtube.com/watch?v=UnCkwIp_614。