【Flink】Flink WindowOperator大概工作流程

1.概述 首先来了一条数据，那么我们要判断这个元素是归属到哪个window了，因为一个数据可能属于多个window，所以这个可能给你的是多个window的序列。 window的计算一定是根据keyBy来计算的。所以要算这个元素的key是什么 然后遍历所有的window 判断这个数据是不是延迟了，如果延迟了，比如这个窗口都过期了，窗口都不存在了，那么就不处理，我觉得这里可以输出到outputTag

>>阅读原文<<