说说Flink 中的窗口?Flink 中的时间有哪几类?
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 还支持会话窗口,它是一种根据数据之间的间隔时间来划分窗口的窗口类型。
原文地址: https://www.cveoy.top/t/topic/hvuT 著作权归作者所有。请勿转载和采集!