flink cep 如何处理超时事件？

[drewfranklin]

Hello all.
 想请教下各位。
 
我有个用户开户超时断点的场景。调研了一下，想通过flink cep 来实现。
 
但是我定义pattern 后发现，我的这个没办法在一条事件数据上完成判定。必须借助和上一事件数据比较之后判断是不是超时。


想知道该如何定义pattern 能够，取到排序之后前后两个两个事件。

[shizk233]

Hi drewfranklin,

flink使用event time，然后类似下面这样可以吗？
Pattern.begin("a").next("b").within(Time.minutes(1));

Best,
shizk233

drewfranklin <[hidden email]> 于2020年7月14日周二 上午11:05写道：

> Hello all.
>  想请教下各位。
>
> 我有个用户开户超时断点的场景。调研了一下，想通过flink cep 来实现。
>
> 但是我定义pattern 后发现，我的这个没办法在一条事件数据上完成判定。必须借助和上一事件数据比较之后判断是不是超时。
>
>
> 想知道该如何定义pattern 能够，取到排序之后前后两个两个事件。