如何向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”，订户））是否可以解决此问题？我无法在不删除该表并再次创建的情况下向该表添加另一条记录，这太昂贵了。

请在Java中共享答案。

Answer 1

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

有关Flink SQL的详细介绍，我建议https://www.youtube.com/watch?v=UnCkwIp_614。