Flink - Table SQL API - 向表中添加列

Question

我想知道是否有办法在 Flink (Java API) 中的表中添加具有常量值的列，类似于 Spark DF/DS 中的 .withColumn 函数？

问候， 巴斯蒂安

Answer 1

如果您在 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 查询没有立即执行。它更类似于在执行前与第二个查询一起自动内联和优化的视图定义。