最后返回state中匹配的步骤数和ck中的步骤数相加进行判定伪代码如下//获取状态state中的数据迭代器 //todo 这里只能get,不能上面传入迭代器,否则迭代一次,就不能迭代第二次了...A事件,后触发BC事件,使用SPM来描述往往非常复杂,业务方使用起来也不是很方便,此处提供一种基于正则表达式的描述,具体的转化如下:2.使用列表数据结构,装载业务方给定的key,把源源不断的给定的用户事件映射为列表的索引...,匹配规则触发&定时型规则的设计方案理解Flink中的Watermark概念在分布式环境下如何推进事件时间Flink中定时器的应用定时规则形如:触发A事件后4分钟内触发BCD事件,该场景比较比较复杂,目前的设计可以满足对定时时间内事件行为的连续序列判断...if (tp.f1 == timestamp){ //如果对应,检查该规则的定时条件(定时条件中包含的就是行为条件列表) TimerCondition...,如何在不停止job的前提下修改规则是一个重要的需求,Drools可以将复杂多变的规则从硬编码中解放出来,以规则脚本的形式存放在文件中,使得规则的变更不需要修正代码重启job可以立即上线Drools热更新流程