Flink 中的窗口是将无限流划分为有限大小的数据块,并对这些数据块进行聚合计算。Flink 支持基于时间和基于数量的窗口,其中基于时间的窗口又分为滚动窗口和滑动窗口。

基于时间的窗口有三类:Processing Time、Event Time 和 Ingestion Time。Processing Time 是指 Flink 处理数据的时间,Event Time 是指数据实际发生的时间,而 Ingestion Time 是指数据进入 Flink 系统的时间。

其中,Processing Time 窗口是最简单的窗口类型,它是根据 Flink 系统的本地时钟来触发窗口计算的。Event Time 窗口则需要根据数据的时间戳来触发窗口计算,通常需要进行事件时间的水印处理。Ingestion Time 窗口则是在数据进入 Flink 系统之后,使用数据的时间戳和进入时间来计算窗口。

除了基于时间的窗口,Flink 还支持基于数量的窗口,例如固定数量的数据块或固定数量的元素。此外,Flink 还支持会话窗口,它是一种根据数据之间的间隔时间来划分窗口的窗口类型。

说说Flink 中的窗口?Flink 中的时间有哪几类?

原文地址: https://www.cveoy.top/t/topic/hvuT 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录