// 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");
1条答案
按热度按时间gwbalxhn1#
如果您在java环境中,这可以通过一个简单的
SELECT
查询并注册结果Table
在目录里。中的第一个sql查询没有立即执行。它更类似于在执行前与第二个查询一起自动排列和优化的视图定义。