In umbrella task FLINK-10232[1] we have introduced CREATE TABLE grammar in our new module flink-sql-parser. And we proposed to use computed column to describe the time attribute of process time in the design doc FLINK SQL DDL[2], so user may create a table with process time attribute as following:
create table T1( a int, b bigint, c varchar, d as PROC_TIME, ) with ( k1 = v1, k2 = v2 ); The column d would be a process time attribute for table T1. There are also many other use cases for computed columns[3]. It may not be a big change here, but may touch the TableSchema, which is a public API for user now, so i'm very appreciate for your suggestions(especially its relationship with the TableSchema). I write a simple design doc here[3]. [1] https://issues.apache.org/jira/browse/FLINK-10232 [2] https://docs.google.com/document/d/1OmVyuPk9ibGUC-CnPHbXvCg_fdG1TeC3lXSnqcUEYmM [3] https://docs.google.com/document/d/110TseRtTCphxETPY7uhiHpu-dph3NEesh3mYKtJ7QOY/edit?usp=sharing Best, Danny Chan