如何向 Apache Flink 表添加新行

Question

是否可以向 flink 表添加新记录/行？例如，我有以下表配置：

ExecutionEnvironment env = TableEnvironmentLoader.getExecutionEnvironment();
BatchTableEnvironment tableEnv = TableEnvironmentLoader.getBatchTableEnvironment();
Table subscribers = tableEnv.fromDataset(subscribers, "firstName, lastName, age");
tableEnv.registerTable("subscribers", subscribers);

现在让我们假设稍后我有一个包含相同字段的附加数据集或元组 3：firstName、lastName、age。如何将其添加到现有的 flink 订阅者表中？使用动态表或其他注册表的方式(例如：tableEnv.registerTemporaryView("订阅者"，订阅者((可以解决问题吗？我无法在不删除它并再次创建它的情况下向该表添加另一条记录，这太昂贵了。

请在 Java 中分享答案。

Answer 1

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

对于 Flink SQL 的可靠介绍，我建议 https://www.youtube.com/watch?v=UnCkwIp_614。