session window可以满足你的需求的,你可以查一下 session window的例子


| |
熊云昆
|
|
邮箱:[email protected]
|

签名由 网易邮箱大师 定制

在2020年10月30日 13:07,sunfulin 写道:



hi,
session window能处理这种超时事件么?不知道有没有例子可以参考参考哈。














在 2020-10-30 11:12:55,"naisili Yuan" <[email protected]> 写道:
> 不知道理解错没有, 感觉你这个场景使用session windows能解决
>
>sunfulin <[email protected]> 于2020年10月30日周五 上午11:01写道:
>
>> hi,community,
>> 我最近有一个业务场景,需要基于消息流和具体的业务逻辑判断生成超时事件,考虑通过flink
>> cep来实现。不过在这个场景中,需要针对输入的消息,判断如果一个小时内没有匹配的数据到来,就需要把该事件输出。
>> 目前的cep机制,应该需要下一个事件消息到来时才会输出事件。想请教下各位大神,针对这个诉求有没有啥好的方案。
>> 感谢。

回复