Flink的Time详解之时间语义Time介绍

Flink的Time详解之时间语义Time介绍

对于流式数据处理，最大的特点是数据上具有时间的属性特征，Flimk 根据时间产生的位置不同，将时间区分为三种时间语义，分别为事件生成时间（Event Time）、事件接入时 间（Ingestion Time）和事件处理时间（Processing Time）。

Event Time：事件产生的时间，它通常由事件中的时间戳描述。Ingestion Time：事件进入 Flink 的时间。Processing Time：事件被处理时当前系统的时间。

1.时间语义 Time

2.设置时间语义

在 Flink 中默认情况下使用是 Process Time 时间语义，如果用户选择使用 Event Time 或 者 Ingestion Time 语 义 ， 则 需 要 在 创 建 的 StreamExecutionEnvironment 中 调 用 setStreamTimeCharacteristic() 方 法 设 定 系 统 的 时 间 概 念 ， 如 下 代 码 使 用 TimeCharacteristic.EventTime 作为系统的时间语义：

//设置使用EventTime streamEnv.setStreamTimeCharacteristic(TimeCharacteristic.EventTime) //设置使用IngestionTime streamEnv.setStreamTimeCharacteristic(TimeCharacteristic.IngestionTime)

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。