Apache Flink 零基础入门(五):流处理核心组件 Time&Window 深度解析

  1. 云栖社区>
  2. 博客>
  3. 正文

Apache Flink 零基础入门(五):流处理核心组件 Time&Window 深度解析

Ververica 2019-08-05 17:15:17 浏览334
展开阅读全文

作者:邱从贤

1. Window & Time 介绍

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

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

1
2

2. Window API 使用

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

代码来自 flink-examples:

3

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

网友评论

登录后评论
0/500
评论
Ververica
+ 关注