table sql api-向表中添加列

mjqavswn  于 2021-06-21  发布在  Flink
关注(0)|答案(1)|浏览(361)

我想知道是否有一种方法可以向flink(JavaAPI)中的表中添加一个具有常量值的列,比如SparkDF/ds中的.withcolumn函数?
你好,巴斯蒂安

gwbalxhn

gwbalxhn1#

如果您在java环境中,这可以通过一个简单的 SELECT 查询并注册结果 Table 在目录里。

// add constant column
Table withColumn = tEnv.sqlQuery("SELECT a, b, c, 'MyConstant' AS d FROM origTable");
// register new table
tEnv.registerTable("tableWithColumn", withColumn);

// query table with constant column
Table result = tEnv.sqlQuery("SELECT * FROM tableWithColumn");

中的第一个sql查询没有立即执行。它更类似于在执行前与第二个查询一起自动排列和优化的视图定义。

相关问题