SessionWindow(会话窗口)
会话窗口按活动会话对对窗口进行区分。这种窗口和前面两种都不同,它既没有固定大小,也没有固定的开始时间和结束时间,它也不可能重叠,它完全是按照计算任务的活动状态来创建窗口的。
例如,如果某个计算任务量较大,那么它会持续通过会话窗口计算元素,直到任务结束;而如果暂时没有计算任务,那么一段时间之后窗口就会关闭。
这和浏览器或其他客户端上的用户会话机制是一样的。
会话窗口的代码模式如下。
原创大约 7 分钟
会话窗口按活动会话对对窗口进行区分。这种窗口和前面两种都不同,它既没有固定大小,也没有固定的开始时间和结束时间,它也不可能重叠,它完全是按照计算任务的活动状态来创建窗口的。
例如,如果某个计算任务量较大,那么它会持续通过会话窗口计算元素,直到任务结束;而如果暂时没有计算任务,那么一段时间之后窗口就会关闭。
这和浏览器或其他客户端上的用户会话机制是一样的。
会话窗口的代码模式如下。