前面我们已经定义好了如何使用table API,Flink SQL来进行添加,时间戳

然后我们再来看,如何用table api,以及flink sql来开窗口

首先看 1.group windows 就是在table api 以及 flink sql中进行开窗口,然后

分组操作

2.然后over windows 就是基于分组好的窗口以及数据,进行计算.

先看group window怎么做,可以看到

需要首先用一个inputTable.window() 这里as 的w 就是定义了一个窗口的别名

然后接着groupBy("w,a"),就是基于w这个窗口来,根据a这个字段作为key进行分组.

然后.select 就是后面的,聚合,以及计算操作了.