AI
推荐
模板社区
专题
登录
免费注册
首页
流程图
详情
Flink的watermark原理图
2021-12-15 11:11:03
27
举报
分享方式
免费使用
Flink的watermark水印机制原理图
大数据
flink
watermark
模板推荐
作者其他创作
大纲/内容
3
w(9)
11
当watermark=窗口结束时间5的时候，触发窗口执行
15
9
7
4
w(3)
w(8)
w(5)
14
16
5
10
2
13
12
WindowsT1-T5
触发执行
6
w(1)
w(10)
1
w(0)
WindowsT5-T10
Watermark原理图
w(6)
2、乱序的Stream的Watermark(指定延迟时间t=2，watermark=maxtime - 2)
w(7)
8
w(2)
当watermark=窗口结束时间的时候，触发窗口执行此时watermark=maxtime=EventTime
w(4)
注意：这里事件4、2、3、6、9、8都是迟到的乱序元素所以不能取它们的EventTime去减t，而是取这之前的最大的一个时间maxEventTime只有maxEventTime才有意义，才有去容忍延迟时间的意义。所以要拿之前maxEventTime不断跟当前的元素的时间做对比，取得真正的maxEventTime
1、有序的Stream的Watermark(t=0，watermark=maxtime-0=maxtime)此时watermark=maxtime=EventTime
收藏
立即使用
Flink的watermark原理图
doublexi
职业：暂无
去主页
Collect
Get Started
图10 差分检波法解调原理图
Collect
Get Started
flink pipe
Collect
Get Started
多线程原理图
Collect
Get Started
图7 鉴频器解调原理图
评论
0
条评论
下一页
Document
