前面我们已经定义好了如何使用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 就是后面的,聚合,以及计算操作了.
