AI
推荐
模板社区
专题
登录
免费注册
首页
流程图
详情
window End job
2023-03-09 17:30:45
16
举报
分享方式
免费使用
123
内容运营
模版推荐
作者其他创作
大纲/内容
清除缓存
否
windowEnd Job
数据流
stepId改变的时候试切窗口
是否切成功
rawdata
keyby traceId
eventEnd
最后试切窗口， 需要判断该windowId是否之前已切成功过， 如果成功， 不在试切
eventStart
缓存该分区内所有的rawData
KeyedBroadcastProcessFunction
输出mainfab_window_data_topic
自定义分区，设置64个分区
connect
数据流处理
配置广播流
数据下发下游
缓存evenStart和IControlWindow用于切窗口
对windowConfig配置里面的sensorName做hash然后除以64取余
是
对sensorName做hash然后除以64取余
window切窗口
keyBy traceId|partitionId
rawData
union
MainFanWindowEndBySensorKeyedProcessFunction
该分区切出来的stepId切窗口结果， 和Window配置
保留该windowId已经切成功的状态， 同时将数据下发下游
根据startTIme和stopTime过滤rawData，
收藏
立即使用
window End job
收藏
立即使用
在线Flink数据流程图
188212_PO
职业：暂无
去主页
Collect
Get Started
在线帮助
Collect
Get Started
在线自测
Collect
Get Started
环形流程图
Collect
Get Started
MSite Version 3.0
评论
0
条评论
下一页
Document
