Flink基础教程

40

｜

第

4

章

4.3

　时间概念

在流处理中，主要有两个时间概念

1

。

•

事件时间

，即事件实际发生的时间。更准确地说，每一个事件都有一个

与它相关的时间戳，并且时间戳是数据记录的一部分（比如手机或者服

务器的记录）。事件时间其实就是时间戳。

•

处理时间

，即事件被处理的时间。处理时间其实就是处理事件的机器所

测量的时间。

图

4-4

说明了事件时间和处理时间的区别。

事件时间

处理时间

星球大战4

新希望

星球大战5

帝国反击战

星球大战6

绝地归来

星球大战1

幽灵的威胁

星球大战2

克隆人的进攻

星球大战3

西斯的复仇

星球大战7

原力觉醒

图 4-4：事件时间顺序与处理时间顺序不一致的乱序事件流

以《星球大战》系列电影为例。首先上映的

3

部电影是该系列中的第

4

、

5

、

6

部（这是事件时间），它们的上映年份分别是

1977

年、

1980

年和

1983

年

（这是处理时间）。之后按事件时间上映的第

1

、

2

、

3

、

7

部，对应的处理时

间分别是

1999

年、

2002

年、

2005

年和

2015

年。由此可见，事件流的顺序

可能是乱的（尽管年份顺序一般不会乱）。

注

1

：

本章涉及的许多想法都是由

Google Dataflow

团队（即现在的

Apache Beam

团队）

提出的。团队成员包括

Tyler Akidau

和

Frances Perry

等人。如果想了解更多关于

Dataflow

模型的内容，请参考

Tyler Akidau

的文章

Streaming 101

和

Streaming 102

。

Flink

处理时间和窗口的机制很大程度上来源于

Tyler Akidau

等人所著的关于

Dataf ...