大数据_Flink_Java版_Table API 和 Flink SQL(13)_事件时间特性---Flink工作笔记0093

然后我们再来看,怎么在table api flink sql中添加事件时间,

可以看到也是有三种办法,1.dataStream转换成表的时候指定

2.在Table schema中指定 3.在ddl中指定

先看一下在dataStream转换成dataTable的时候指定可以看到上面两种方式,

可以看到,第一种,上面,直接id,timestamp.rowtime 这样指定的

第二种rt.rowtime这样指定的.

我们去看看怎