欢迎光临散文网 会员登陆 & 注册

如何使用定长和可变的Session gap来建立会话窗口?

2023-08-01 10:35 作者:ingemar-  | 我要投稿

会话窗口根据Session gap切分不同的窗口,当一个窗口在大于Session gap的时间内没有接收到新数据时,窗口将关闭。

在这种模式下,窗口的长度是可变的,每个窗口的开始和结束时间并不是确定的。

我们可以设置定长的Session gap,也可以使用SessionWindowTimeGapExtractor动态地确定Session gap的长度。

下面的代码展示了如何使用定长和可变的Session gap来建立会话窗口,其中SessionWindowTimeGapExtractor[T]的泛型T为数据流的类型,我们可以根据数据流中的元素来生成Session gap。


如何使用定长和可变的Session gap来建立会话窗口?的评论 (共 条)

分享到微博请遵守国家法律