大数据抽希时序图

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