Apache Flink 零基础入门（五）：流处理核心组件 Time&Window 深度解析

作者：邱从贤

1. Window & Time 介绍

Apache F （以下简称 F ） 是一个天然支持无限流数据处理的分布式计算框架，在 F 中 Window 可以将无限流切分成有限流，是处理有限流的核心组件，现在 F 中 Window 可以是时间驱动的（Time Window），也可以是数据驱动的（Count Window）。

下面的代码是在 F 中使用 Window 的两个示例

2. Window API 使用

从第一部分我们已经知道 Window 的一些基本概念，以及相关 API，下面我们以一个实际例子来看看怎么使用 Window 相关的 API。

代码来自 f -examples：

上面的例子中我们首先会对每条数据进行时间抽取，然后进行 keyby，接着依次调用 window()，e