news 2026/7/6 14:30:10

Flink 翻滚窗口、滑动窗口、会话窗口核心区别

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
Flink 翻滚窗口、滑动窗口、会话窗口核心区别

        Flink 中的翻滚窗口(Tumbling Window)滑动窗口(Sliding Window)会话窗口(Session Window)是处理流数据的三大核心窗口类型,用于将无限的流数据切割为有限的 “数据块” 进行批量计算。三者的核心差异体现在窗口划分方式、数据重叠性、触发机制上,适用于不同的业务场景。以下是详细的对比与解析。

一、核心定义与窗口划分逻辑

1. 翻滚窗口(Tumbling Window):固定大小、无重叠、连续划分

        翻滚窗口是大小固定、无重叠、连续划分的窗口,数据会被严格分配到一个且仅一个窗口中,窗口之间无缝衔接。

  • 划分规则:以固定的时间 / 数据量间隔划分窗口,例如:
    • 时间翻滚窗口:每 5 分钟一个窗口(00:00-00:05、00:05-00:10、00:10-00:15……);
    • 计数翻滚窗口:每 100 条数据一个窗口(1-100 条、101-200 条、201-300 条……)。
  • 核心特点:窗口之间完全独立,无数据重叠,计算结果是 “阶段性的完整统计”。
  • 形象比喻:像切面包一样,将流数据切成一段段等长的面包片,每片之间没有重叠。

2. 滑动窗口(Sliding Window):固定大小、有重叠、滑动步长控制

        滑动窗口是大小固定、可重叠的窗口,窗口的划分由 ** 窗口大小(Window Size)滑动步长(Slide Step)** 两个参数控制。

  • 划分规则
    • 窗口大小:窗口的时间 / 数据量长度(如 5 分钟);
    • 滑动步长:窗口每次滑动的时间 / 数据量间隔(如 2 分钟)。例如:
    • 时间滑动窗口:窗口大小 5 分钟,滑动步长 2 分钟(00:00-00:05、00:02-00:07、00:04-00:09……);
    • 计数滑动窗口:窗口大小 100 条,滑动步长 50 条(1-100 条、51-150 条、101-200 条……)。
  • 核心特点:数据可能被分配到多个窗口中(重叠部分的数据会被多次计算),计算结果是 “高频的增量统计”。
  • 关键参数关系
    • 当滑动步长 = 窗口大小时,滑动窗口退化为翻滚窗口;
    • 当滑动步长 < 窗口大小时,窗口存在重叠(最常见场景);
    • 当滑动步长 > 窗口大小时,窗口之间会出现间隙(数据可能被遗漏,极少使用)。

3. 会话窗口(Session Window):无固定大小、基于超时、非连续划分

        会话窗口是 ** 无固定大小、基于会话超时(Session Gap)** 划分的窗口,用于处理间歇性的数据流,窗口的开始和结束由数据的到达时间决定。

  • 划分规则
    • 当有数据到达时,若当前
版权声明: 本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:809451989@qq.com进行投诉反馈,一经查实,立即删除!
网站建设 2026/7/6 6:13:15

Xiaomi 商城页面布局(部分)

HTML部分&#xff1a;<!DOCTYPE html> <html lang"en"> <head><meta charset"UTF-8"><meta name"viewport" content"widthdevice-width, initial-scale1.0"><title>Document</title><li…

作者头像 李华
网站建设 2026/7/6 5:05:02

运料小车装卸料控制:西门子1200PLC与TP700触摸屏联机仿真博途16

运料小车装卸料控制西门子1200PLC和TP700触摸屏联机仿真博途16最近在车间折腾运料小车的自动化改造&#xff0c;用西门子1200PLC搭了个装卸料控制系统。正好手头有TP700触摸屏&#xff0c;索性在博途V16里搞了个联合仿真&#xff0c;省得去现场调试吃灰。这个方案特别适合产线还…

作者头像 李华
网站建设 2026/7/6 4:15:08

S32K311启动过程中,向量表重定向

在MCU的启动过程中&#xff0c;NXP官方提供的启动代码会对中断向量表进行重定向&#xff0c;将向量表从flash定向到ram。具体实现分析如下。Vector_Table.sSECTION .intvec:DATA:ROOT(2&#xff09;通过这个命令&#xff0c;声明一个.intvec的段&#xff0c;这条指令下面申明的…

作者头像 李华
网站建设 2026/7/6 3:36:00

从蓝图到产线:高效产品信息传递的桥梁建设

在制造业中&#xff0c;研发设计的精妙构思与生产部门的高效执行之间&#xff0c;存在着一条至关重要的信息传递链。这条链路的畅通与否&#xff0c;直接决定了产品能否从图纸精准、准时地转化为合格的商品。本文将深入探讨这一过程的标准实践、常用工具、潜在挑战及其优化方案…

作者头像 李华
网站建设 2026/7/6 10:48:25

时间复杂度

这种题目是数据结构与算法考研&#xff08;如408&#xff09;或面试中的高频送分题&#xff0c;但也是高频陷阱题。 复习这类题目&#xff0c;不要靠“猜”或者“死记硬背”&#xff0c;而是要掌握一套**“数学建模”**的方法。一旦你建立了数学直觉&#xff0c;这类题看一眼就…

作者头像 李华