如何向Apache Flink表添加新行

问题描述 投票:0回答:1

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

java apache-flink flink-streaming flink-sql flink-batch
1个回答
0
投票

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

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

© www.soinside.com 2019 - 2024. All rights reserved.