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