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