Flink窗口的概念和分类

  • 开发
  • 46

窗口的概念

Flink是一种流式计算引擎，主要是来处理无界数据流的，数据源源不断、无穷无尽。想要更加方便高效地处理无界流，一种方式就是将无限数据切割成有限的“数据块”进行处理，这就是所谓的“窗口”（Window）。
注意：Flink中窗口并不是静态准备好的，而是动态创建——当有落在这个窗口区间范围的数据达到时，才创建对应的窗口。另外，这里我们认为到达窗口结束时间时，窗口就触发计算并关闭。

窗口的分类

按照驱动类型分

在这里插入图片描述

按照窗口分配数据的规则分类

根据分配数据的规则，窗口的具体实现可以分为4类：滚动窗口（Tumbling Window）、滑动窗口（Sliding Window）、会话窗口（Session Window），以及全局窗口（Global Window）。

滚动窗口

在这里插入图片描述

滑动窗口

在这里插入图片描述

会话窗口

在这里插入图片描述

全局窗口

在这里插入图片描述

阅读全部

相关推荐

  7. Flink物理分区概念与分类详解

    2023-12-19 22:30:02       32 阅读

最近更新

  3. docker php8.1+nginx base 镜像 dockerfile 配置

    2023-12-19 22:30:02       94 阅读

  4. Could not load dynamic library ‘cudart64_100.dll‘

    2023-12-19 22:30:02       101 阅读

  9. 在Django里面运行非项目文件

    2023-12-19 22:30:02       82 阅读

  19. Python语言-面向对象

    2023-12-19 22:30:02       91 阅读

  20. 如何分清楚常见的 Git 分支管理策略Git Flow、GitHub Flow 和 GitLab Flow

    2023-12-19 22:30:02       85 阅读

热门阅读

  2. 【ES】--Elasticsearch的深度分页/内存超限等问题

    2023-12-19 22:30:02       58 阅读

  5. 数据科学家为什么应该了解 Llama: 简单易懂的 Python 数据科学库

    2023-12-19 22:30:02       53 阅读

  6. 华三交换机基础配置

    2023-12-19 22:30:02       67 阅读

  7. Node.js和MySQL编写接口并进行请求

    2023-12-19 22:30:02       55 阅读

  8. SpringBoot整合Redis

    2023-12-19 22:30:02       60 阅读

  9. 【大厂面试】之招银网络

    2023-12-19 22:30:02       43 阅读

  11. 第28节: Vue3 条件渲染

    2023-12-19 22:30:02       70 阅读

  19. 测试用例设计方法：场景用例破云

    2023-12-19 22:30:02       61 阅读

  20. 【Jenkins】Pipeline 简单使用

    2023-12-19 22:30:02       77 阅读

  22. 深度学习 计算预测和真实值之间的差异

    2023-12-19 22:30:02       60 阅读

  29. 打破“造车”嫌疑，华为“造车”另辟蹊径

    2023-12-19 22:30:02       61 阅读

  30. 如何获取旧版 macOS

    2023-12-19 22:30:02       74 阅读