截止目前当前最新版本,如果以机器时间(useSystemTime=true)触发窗口关闭,就不存在最后一个窗口无法关闭的问题。如果以事件时间(useSystemTime=false),那么可以将outputTable设置为keyedTable,然后设置updateTime小于sessionGap,就可以将最后一个窗口输出到结果表中。
下一个版本规划会在该引擎中增加一个参数,在以事件时间(useSystemTime=false)触发窗口关闭的情况下,可以设置最后一批数据接收到后,间隔多少时间强制关闭最后一个计算窗口的参数,这样outputTable可以选择任意类型的table来接收结果的输出。可以更好地处理上述场景。