window End job
2023-03-09 17:30:45 15 举报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，
收藏
收藏
0 条评论
下一页
