将输入流拆分为多个窗口并单独处理

pn9klfpd  于 2021-06-25  发布在  Flink
关注(0)|答案(1)|浏览(354)

我有一个数据流。我必须申请窗口功能为1小时,2小时,3小时…24小时。每个分割都有自己的窗口功能
如何有效地拆分Windows。
我能想到的最肮脏的方式就是

for(int i=1; i < 24 ;i++){
   inputStream.keyBy("id").timeWindow(Time.hours(i)).apply(..);
}
r7s23pms

r7s23pms1#

更有效的方法是基于每小时触发一次的eventtimetrigger(假设您使用的是eventtime,否则是processingtimetrigger)实现一个自定义触发器。

相关问题