当前位置: 首页 > ds >正文

flink中的窗口的介绍

本文重点

无界流会源源不断的产生数据,有的时候我们需要把无界流进行切分成一段一段的有界数据,把一段内的所有数据看成一个整体进行聚合计算,这是实现无界流转成有界流的方式之一。

为什么需要窗口

数据是源源不断产生的,我们可能只关心某个周期内的统计结果。比如电费是不断产生的,我们可能会关注每个月用了多少,此时我们就定义定义一个窗口,大小为1个月,从而得到一个月内的电量使用结果。

总之一句话,窗口可以帮助我们获取无界数据流中的某段窗口有界数据的统计结果。

窗口的介绍

现在有一个温度传感器,它不定时上报当前环境的温度。我们现在有一个任务就是每10分钟统计一次当前环境的温度(平均值)

现在我们定义一个窗口,这个窗口的大小为10分钟,数学表达就是[0,10),假设现在温度传感器温度产生的时间(事件时间)和数据如下:

1分钟   46
2分钟   48
3分钟   45
7分钟   45
9分钟    46
10分钟  43
11分钟   42
12分钟   49
17分钟    49
21分钟   49
25分钟   43
29分钟    45

如果我们将它画出来,我们可以得到下面的图像:

http://www.xdnf.cn/news/19807.html

相关文章:

  • mysql5.6+分页时使用 limit+order by 会出现数据重复问题
  • Mysql杂志(七)
  • Shell脚本入门:从零到精通
  • C# 原型模式(C#中的克隆)
  • “转”若惊鸿,电磁“通”——耐达讯自动化RS485转Profinet点亮能源新章
  • 【NestJS】HTTP 接口传参的 5 种方式(含前端调用与后端接收)
  • 【卷积神经网络】卷积神经网络的三大核心优势:稀疏交互、参数共享与等变表示
  • C++之基于正倒排索引的Boost搜索引擎项目介绍
  • 如何解决pip安装报错ModuleNotFoundError: No module named ‘black’问题
  • 【提示词】...(后续单元)在Prompt 的作用
  • 【linux仓库】万物至简的设计典范:如何用‘文件’这一个概念操纵整个Linux世界?
  • 在Docker中安装MySQL时3306端口占用问题
  • 论文学习30:LViT: Language Meets Vision Transformerin Medical Image Segmentation
  • 使用云手机进行游戏搬砖划算吗?
  • 国内真实的交换机、路由器和分组情况
  • 【保姆级喂饭教程】把chrome谷歌浏览器中的插件导出为CRX安装包
  • LeetCode 925.长按键入
  • 数据结构:希尔排序 (Shell Sort)
  • 【51单片机】【protues仿真】基于51单片机呼叫系统
  • 基于Force-closure评估的抓取计算流程
  • 生成知识图谱与技能树的工具指南:PlantUML、Mermaid 和 D3.js
  • 【AI报表】JimuReport 积木报表 v2.1.3 版本发布,免费可视化报表和大屏
  • 【leetcode】222. 完全二叉树的节点个数
  • Altium Designer中的Net-Tie:解决多网络合并与电气隔离的利器
  • CPTS-Vintage 票据,基于资源的约束委派 (RBCD),DPAPI密钥
  • 自制扫地机器人(二) Arduino 机器人避障设计——东方仙盟
  • Veo Videos Generation API 对接说明
  • 鸿蒙NEXT表单选择组件详解:Radio与Checkbox的使用指南
  • 开源 C++ QT Widget 开发(十)IPC进程间通信--共享内存
  • 零跑汽车8月交付57066台,同比增长超88%