大数据抽希时序图
2022-02-21 19:18:53 1 举报大数据抽希时序图
作者其他创作
大纲/内容
main()
通过单例CepManager创建cep规则
1、获取启动参数ruleNo值2、启动主程序
start(ruleNo)
ActivityVo初始化 ，获取当前RuleVo下所有关联的 activity_actions数据放到activitys Map中
活动列表监控过期时间，找到activitys中当前时间-更新时间和当前时间-创建时间 <Activity_time的数据，转化为list
SinkManager
start()
init(rj)
获取cep复杂时间的规则，为了控制控制event匹配的个数，定义 cons、times、times_flag的AfterMatchSkipStrategy skip策略
ActivityManager
CepManager
getPattern(rj)
创建cep过滤规则
RaeCepUtil
return DataStream
1、通过ruleNo获取RuleVo对象2、创建流计算执行环境，解决flink在spring容器访问空指针问题3、设置并行度、检查点属性4、判断VO值是否为cep 15、设置流计算为事件时间6、
RaengApplication
定义Pattern的条件、命名、出现次数等规则
判断kafka、es或者其HDFS，打印抽取的消息
创建规则、设置并行度
flink+kafka
0 条评论
下一页
