AudienceStart 任务
2023-03-27 16:09:08 0 举报AudienceStart flink任务流程
作者其他创作
大纲/内容
离线圈人
NewUserPushProcess
Filter
connect
element1：process1、放入所有是全部人员的流程Key->{channelType}:{channelId}Value->processIds(Set<String>)
Source：processConsumer
font color=\"#323232\
OnTimer
旁路
Source：userActionConsumer
GetStartNodeProcess
图标解释
souce：bos-ma-process-handle(groupid:audienceStartNode)ncdp_dwd_user_action_bos（groupid:audienceStartNodev1）bos-ma-history-uid(groupid:audienceStartNode)
Source
element2：userAction1、获取当前流程下的 当前事件的所有节点ID
1、过滤userID是否重复，并将userid暂存2秒2、对象转换成流程需要执行的对象
Sink
Start：主要处理流程设置中判断规则为全部的流程数据，即所有用户都可以进入该流程
sink：bos-ma-audience-process-initbos-ma-audience-start-node
FlatMap：UserActionFlatMap
HistoryUserPollProcess
union
Sink：startNodeProducer
FlatMap：序列化processDigraph
element2：historyUid1、根据processid从stage中获取流程配置2、过滤测试店铺（目测没用到）3、输出行为-流程-节点的对应信息
Audience Start 任务
NewUserPollCoProcess
userid
element2：userAction将行为与流程进行关联根据用户行为找到所有的流程id
startNodeAllUidStream
Source：historyUidConsumer
Sink：processInitNotifyProducer
element1：process1、根据operator修改stage中的流程配置2、同时创建旁路流
Stage
Filter：processType: 2
element1：process1、对stage中的有关流程数据进行处理
Filter：ValidUserId
Process
收藏
0 条评论
下一页
