Re: 回复: 回复:关于watermark和window

2021-05-18 文章 yidan zhao
没什么传不传的。processWatermark中应该就会直接将2窗口都处理掉了。 曲洋 于2021年5月10日周一 上午10:31写道: > > > > 对的,就是两个窗口同时存在,(3,1,2)(6,5,4)这就是两个窗口,然后watermark(7)来了,但是我不知道这个watermark是同时触发 > > 两个窗口都计算,还是触发第一个,因为watermark也是一种特殊的数据,我看源码也没有找到当一个operater进行processWatermark之后 > 会不会把这个watermark进一步传递给并行的同时存在的窗口,也来触发它。 > > > > > > > > >

Re:回复: 回复:关于watermark和window

2021-05-09 文章 曲洋
对的,就是两个窗口同时存在,(3,1,2)(6,5,4)这就是两个窗口,然后watermark(7)来了,但是我不知道这个watermark是同时触发 两个窗口都计算,还是触发第一个,因为watermark也是一种特殊的数据,我看源码也没有找到当一个operater进行processWatermark之后 会不会把这个watermark进一步传递给并行的同时存在的窗口,也来触发它。 在 2021-05-08 19:12:59,"明启 孙" <374060...@qq.com> 写道: