作者回复: 谢谢你的提问!是的,按照你说的情景最终只会产生一个会话窗口。
作者回复: 谢谢你的留言!
1、是的呢,eagle eye啊,已经给编辑部反映修改了。
2、如果我没有理解错你的留言的话,应该是每次得到一个新数据后,如果这个新数据的时间戳和之前的会话窗口边界相差没有超过Duration Gap的话,就将这个新数据归入会话窗口中,并且再将窗口向外延时Duration Gap的时长。
作者回复: 谢谢你的留言!动态定义sessino gap说实话我没有尝试过,所以我不确定给同一个PCollection设置多次Sessions Window的话会不会报错。
全局窗口的一个用处是在处理无边界数据的数据集时,配合触发器使用。例如每隔N段时间计算现有的所有数据平均值。
自定义窗口Beam现在应该是不支持的。