是否可以向 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分享答案。
最佳答案
听起来你想要的是使用 dynamic table在StreamTableEnvironment中。动态表的要点在于它可以不断更新。
对于 Flink SQL 的详细介绍，我推荐 https://www.youtube.com/watch?v=UnCkwIp_614 .
关于java - 如何向 Apache Flink 表添加新行，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/62269425/