我有一个数据流。我必须申请窗口功能为1小时,2小时,3小时…24小时。每个分割都有自己的窗口功能如何有效地拆分Windows。我能想到的最肮脏的方式就是
for(int i=1; i < 24 ;i++){ inputStream.keyBy("id").timeWindow(Time.hours(i)).apply(..); }
r7s23pms1#
更有效的方法是基于每小时触发一次的eventtimetrigger(假设您使用的是eventtime,否则是processingtimetrigger)实现一个自定义触发器。
1条答案
按热度按时间r7s23pms1#
更有效的方法是基于每小时触发一次的eventtimetrigger(假设您使用的是eventtime,否则是processingtimetrigger)实现一个自定义触发器。