如果数据源里的时间是long类型，那么使用BIGINT 接收，然后转换TIMESTAMP（这里的转换只接受‘‘秒”级的时间戳）

"   addTime BIGINT ,\n" +

"  `ts` as TO_TIMESTAMP(FROM_UNIXTIME(addTime/1000, 'yyyy-MM-dd HH:mm:ss'))

 如果数据源里的时间是string类型，例如 (2019-02-23 15:38:59)

ts as TO_TIMESTAMP(FROM_UNIXTIME(UNIX_TIMESTAMP('ts'), 'yyyy-MM-dd HH:mm:ss'))

 然后就可以创建水位线

watermark for ts as ts- interval '5' second

 在flinkSQL写一些开窗操作了,演示一个滚动窗口count计数的操作

select window_start,window_end,count(1) ct from TABLE (" +
                " TUMBLE(TABLE kafkaGoods,DESCRIPTOR(ts),INTERVAL '10' SECONDS)" +
                ") group by window_start,window_end

第一次发帖，当是做笔记了~~~~