,需要在上述Demo的基础上新增一个State的查询服务,跨界查询中,需要保留在ck中查询到的步骤数,根据ck中最大匹配步骤数,来修减(截取)条件中的事件序列,注意在state中时间范围要在业务规则内,...最后返回state中匹配的步骤数和ck中的步骤数相加进行判定伪代码如下//获取状态state中的数据迭代器 //todo 这里只能get,不能上面传入迭代器,否则迭代一次,就不能迭代第二次了...return cnt;复杂行为序列分析的设计方案统一查询的表达方式1.业务方会给定开发人员埋点key,key一般是用Super Position Model来描述的,复杂的行为序列一般形如:连续触发两次...,匹配规则触发&定时型规则的设计方案理解Flink中的Watermark概念在分布式环境下如何推进事件时间Flink中定时器的应用定时规则形如:触发A事件后4分钟内触发BCD事件,该场景比较比较复杂,目前的设计可以满足对定时时间内事件行为的连续序列判断...if (tp.f1 分析首先是为什么要有缓存