【Flink系列2】时间窗口

引出 对于流处理系统来讲，流入的消息是无限的，因此对于聚合或是链接等操做，流处理系统须要对流入的消息进行分段，而后基于每一段数据进行聚合或是链接等操做。消息的分段即称为窗口，流处理系统支持的窗口有不少类型，最多见的就是时间窗口，基于时间间隔对消息进行分段处理。本节主要介绍Flink流处理系统支持的各类时间窗口。缓存 对于目前大部分流处理系统来讲，时间窗口通常是根据Task所在节点的本地时钟来进行切

>>阅读原文<<