滚动监听_Flink实战之滚动窗口、滑动窗口WindowsAPI使用示例

Flink实战之窗口WindowsAPI使用示例

介绍

Fink的时间窗口(Window)可以分成两类：

1、CountWindow：按照指定的数据条数生成一个 Window，与时间无关。

2、TimeWindow：按照时间生成 Window。

TimeWindow，可以根据窗口实现原理的不同分成三类：滚动窗口(Tumbling

Window)、滑动窗口(Sliding Window)和会话窗口(Session Window)。

本文介绍滚动窗口(TumblingWindow)、滑动窗口(Sliding Window)，并通过例子说明如何使用这些窗口。

接下来文章介绍CountWindow窗口，欢迎关注。

滚动窗口(Tumbling Windows)使用例子

滚动窗口是将数据依据固定的窗口长度对数据进行切片，特点是时间对齐，窗口长度固定，没有重叠。

滚动窗口分配器将每个元素分配到一个指定窗口大小的窗口中，如：如果你指定了一个 15 分钟大小的滚动窗口。

窗口的创建如下图所示：

示例说明：

进行分组聚合(keyBy：将key相同的分到一个组中) ，定义