java - 如何向 Apache Flink 表添加新行

Question

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

Answer 1

听起来你想要的是使用 dynamic table在StreamTableEnvironment中。动态表的要点在于它可以不断更新。

对于 Flink SQL 的详细介绍，我推荐 https://www.youtube.com/watch?v=UnCkwIp_614 .