背景
在flink的窗口函数运用中，window和windowAll方法总是会引起混淆，特别是结合上GlobalWindow的组合时，更是如此，本文就来梳理下他们的区别和常见用法
window和windowAll的区别
window是KeyStream数据流的方法，其并行度是任意的，也就是最大可以和分组key的数量相同
windowAll是DataStream数据流的方法，其并行度只能是1，也就是所有的元素都会被聚合到一个算子任务上，性能极差
GlobalWindows.create()是一个全局的窗口分配器，
它的作用和TimeWindow或CountWindow一样，都是对元素进行窗口分配，不同点在于GlobalWindows把分区内所有的元素分配到同一个窗口，并且不会触发计算，
而TimeWindow或CountWindow会基于时间或者元素个数对元素进行窗口的分配，并且满足条件就会触发计算
以下是示意图：
GlobalWindows+KeyedStream常见用法如下：
WindowedStream<Integer, Integer, GlobalWindow> keyedWindowedStream = keyedStream.window(GlobalWindows.create()).trigger(PurgingTrigger.of(CountTrigger.of(10)));
GlobalWindows+DataStream常见用法如下：文章来源：https://www.toymoban.com/news/detail-824062.html
AllWindowedStream<Integer, GlobalWindow> allWindowedStream = dataStream.windowAll(GlobalWindows.create()).trigger(PurgingTrigger.of(CountTrigger.of(10)));文章来源地址https://www.toymoban.com/news/detail-824062.html
到了这里，关于flink的window和windowAll的区别的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！
