代理商加盟网站公司专业设计网站

本文重点

在前面课程中我们学习了各种各样的窗口类型，本文我们来看一下如何在FLink中应用这些窗口，在FLink中通过窗口分配器完成这个工作，窗口分配器其实就是在指定窗口的类型。

API

按键分区：基于KeyedStream来调用window方法，传入WindowAssigner参数，返回WindowedStream

 WindowedStream window(<window assigner>)

非按键分区：基于DataStram来调用window方法，传入WindowAssigner参数，返回AllWindowedStream

AllWindowedStream  window(<window assigner>)

时间窗口

滚动处理时间窗口

stream.keyBy(...).window(TumblingProcessingTimeWindows.of(Time.seconds(25)))

.of()方法需要传入一个 Time 类型的参数 size，表示滚动窗口的大小，of()方法还可以传入两个Time 类型的参数：size