版权说明:本文档由用户提供并上传,收益归属内容提供方,若内容存在侵权,请进行举报或认领
文档简介
Flink时间处理机制Flink时间处理机制Flink的无限数据流是一个持续的过程,而时间是判断业务状态是否滞后,数据处理是否及时的重要依据。Flink中针对Stream流事件中的Time分为EventTime、IngestionTime、ProcessingTime。Flink时间处理机制EventTime(事件时间)是指每个事件在其设备上发生的时间,通常由事件中的时间戳来描述。Flink时间处理机制IngestionTime(接收时间)是指事件进入Flink(FlinkSource)的时间,是由SourceOperator自动根据当前时间生成的,每个事件将进入Flink时的时间作为时间戳。ProcessingTime(处理时间)是指事件被处理时机器当前的系统时间,与机器相关。Flink时间窗口Flink流数据处理过程中经常用到窗口(Window)的概念。基于业务数据方面的考虑,Flink支持两种类型的窗口:一种是基于时间的窗口,即TimeWindow;另一种是基于输入数据数量的窗口,即CountWindow。Flink时间窗口TimeWindow可以分为3种类型,分别是滚动窗口(TumblingWindow,窗口和窗口之间没有数据重叠)、滑动窗口(SlidingWindow,会出现数据重叠)和会话窗口(SessionWindow,由不活动的间隙打断)。
滚动时间窗口Flink时间窗口滑动窗口(SlidingWindow)是在滚动时间窗口的基础上增加了滑动步长(SlideSize),且允许窗口之间的数据发生重叠。Flink时间窗口滚动数量窗口(TrublingCountWindow)会话窗口(SessionWindow)
温馨提示
- 1. 本站所有资源如无特殊说明,都需要本地电脑安装OFFICE2007和PDF阅读器。图纸软件为CAD,CAXA,PROE,UG,SolidWorks等.压缩文件请下载最新的WinRAR软件解压。
- 2. 本站的文档不包含任何第三方提供的附件图纸等,如果需要附件,请联系上传者。文件的所有权益归上传用户所有。
- 3. 本站RAR压缩包中若带图纸,网页内容里面会有图纸预览,若没有图纸预览就没有图纸。
- 4. 未经权益所有人同意不得将文件中的内容挪作商业或盈利用途。
- 5. 人人文库网仅提供信息存储空间,仅对用户上传内容的表现方式做保护处理,对用户上传分享的文档内容本身不做任何修改或编辑,并不能对任何下载内容负责。
- 6. 下载文件中如有侵权或不适当内容,请与我们联系,我们立即纠正。
- 7. 本站不保证下载资源的准确性、安全性和完整性, 同时也不承担用户因使用这些下载资源对自己和他人造成任何形式的伤害或损失。
最新文档
- 2025届福建省南安一中高三二诊模拟考试生物试卷含解析
- 2025届山西省忻州一中等四校中学高三压轴卷生物试卷含解析
- 广西壮族自治区普通高中2025届高考临考冲刺生物试卷含解析
- 2025届安徽皖江名校高三3月份模拟考试生物试题含解析
- 广东省陆丰市东海中学2025届高考全国统考预测密卷生物试卷含解析
- 广东省中山一中等七校联合体重点中学2025届高三第二次模拟考试生物试卷含解析
- 安徽省砀山县2024届中考数学最后一模试卷含解析
- 厦门市大同中学2025届高三第二次联考历史试卷含解析
- 家居加盟店转让协议书范本
- 农民工家庭迁移协议书范本
- 体表肿物课件
- 学术论文的撰写方法与规范课件
- 科学研究方法与论文写作课件
- 2022-2023学年高中政治统编版必修四:3-2 世界是永恒发展的 课件(30张)
- 新编英汉翻译教程-课件
- 骨科疑难病种清单(2021年版)
- 易制毒、易制爆培训试卷及答案
- 大学英语新生第一课课件
- 银行合作协议书(适用于汽车业务)模版
- 《荷塘月色》与《我与地坛》群文阅读-统编版高中语文必修上册
- 企业水平衡测试方法及程序
评论
0/150
提交评论