为什么不能通过调用addColumns来添加proctime

Question

tableEnv.fromDataStream(xxxStream).addColumns('processTime.proctime)

以上代码将抛出异常：

org.apache.flink.table.api.ValidationException: Window properties can only be used on windowed tables.

但这将起作用

tableEnv.fromDataStream(xxxStream, 'id,  ......, 'processTime.proctime)

但我必须以这种方式重复所有的专栏。

Answer 1

找到了一些解决方法，但不确定是否可以更容易地完成：

Table tmpTable = tableEnv.fromDataStream(my_pojo_datastream);
Schema newSchema = Schema.newBuilder()
.fromResolvedSchema(tmpTable.getResolvedSchema())
.columnByExpression("proc_time", "PROCTIME()")
.build();
Table tmpTableWithProcTIme = tableEnv.fromDataStream(my_pojo_datastream, newSchema);

Answer 2

以下代码适用于我的

Table tmpTable = tableEnv.fromDataStream(my_pojo_datastream,
Schema.newBuilder().columnByExpression("proc_time", "PROCTIME()").build());