createSessionWindowEngine 引擎可以计算最后一条数据吗?

似乎最后一个窗口的数据不会被计算,有什么办法可以计算它吗

请先 登录 后评论

1 个回答

Draco Chen

截止目前当前最新版本,如果以机器时间(useSystemTime=true)触发窗口关闭,就不存在最后一个窗口无法关闭的问题。如果以事件时间(useSystemTime=false),那么可以将outputTable设置为keyedTable,然后设置updateTime小于sessionGap,就可以将最后一个窗口输出到结果表中。

下一个版本规划会在该引擎中增加一个参数,在以事件时间(useSystemTime=false)触发窗口关闭的情况下,可以设置最后一批数据接收到后,间隔多少时间强制关闭最后一个计算窗口的参数,这样outputTable可以选择任意类型的table来接收结果的输出。可以更好地处理上述场景。

请先 登录 后评论