image.png
順著堆棧往下走,到了Window算子的父類AbstractStreamOperator中的processWatermark方法或粮,對于timeServiceManager不為空的情況卤档,要特別處理一下這個watermark怔锌。其實后面就是對于timeServiceManager所管理的所有timeService都處理一下這個watermark。
image.png
如果是到了最大的watermark宋距,那就調(diào)用keySelected方法并且傳了了null值轴踱。
image.png
注意這里的key是null值。
image.png
image.png