根据窗口数据划分的不同,目前 Flink 支持如下 4 种: 滚动窗口,窗口数据有固定的大小,窗口中的数据不会叠加; 滑动窗口,窗口数据有固定的大小,并且有生成间隔; 会话窗口,窗口数据没有固定的大小,根据用户传入的参数进行划分,窗口数据无叠加。 over窗口,它对每一行数据都生成窗口,在窗口上进行聚合,聚合的结果会生成一个新字段。 Flink 中的时间分为三种: 事件时间(Event Time),即事件实际发生的时间; 摄入时间(Ingestion Time),事件进入流处理框架的时间; 处理时间(Process…