[flink-sql]使用tableEnv.sqlUpdate(ddl);方式创表，如何指定rowt

我使用tableEnv.sqlUpdate(ddl);方式创建表

但是我无法像通过流注册方式一样，添加rowtime。我尝试在定义字段上添加rowtime，但是创表语句会报错。

请问在flink中是否支持使用该种方式创建流表，并开窗?

我的例子是一个csv源，我还没有尝试kafka源，但是我看了文档，也没有找到相关描述。

sql创表语句如下：

CREATE TABLE T_UserBehavior(

userId BIGINT,

itemId BIGINT,

categoryId BIGINT,

behavior VARCHAR,

optime BIGINT

) WITH (

'connector.type' = 'filesystem', -- required: specify to connector type

'connector.path' = 'file:///E:\MyGitProject\flink-study\Hot-Item\src\main\resources\UserBehavior-less.csv', -- required: path to a file or directory

'format.type' = 'csv',

'format.fields.0.name' = 'userId', -- required: define the schema either by using type information

'format.fields.0.type' = 'BIGINT',

'format.fields.1.name' = 'itemId',

'format.fields.1.type' = 'BIGINT',

'format.fields.2.name' = 'categoryId',

'format.fields.2.type' = 'BIGINT',

'format.fields.3.name' = 'behavior',

'format.fields.3.type' = 'VARCHAR',

'format.fields.4.name' = 'optime',

'format.fields.4.type' = 'BIGINT'

);*来自志愿者整理的flink邮件归档