理论
1）一条消息来之后，如果太晚，那就直接丢弃
2）如果不丢弃，则表示如果现在放进来，后面有机会来算，所以那就放进来
3）更新watermark时，针对可以算的window输出数据
4）一条消息，最大可以延迟时间=用户自定义容许延迟时间 + window size + watermark发射延迟时间
---
针对第4条，读者可以自己琢磨一下！
本文共 225 字，大约阅读时间需要 1 分钟。
理论
1）一条消息来之后，如果太晚，那就直接丢弃
2）如果不丢弃，则表示如果现在放进来，后面有机会来算，所以那就放进来
3）更新watermark时，针对可以算的window输出数据
4）一条消息，最大可以延迟时间=用户自定义容许延迟时间 + window size + watermark发射延迟时间
---
针对第4条，读者可以自己琢磨一下！
转载于:https://my.oschina.net/qiangzigege/blog/2992720