flink cep超时事件的问题

[sunfulin]

hi，community，
我最近有一个业务场景，需要基于消息流和具体的业务逻辑判断生成超时事件，考虑通过flink cep来实现。不过在这个场景中，需要针对输入的消息，判断如果一个小时内没有匹配的数据到来，就需要把该事件输出。
目前的cep机制，应该需要下一个事件消息到来时才会输出事件。想请教下各位大神，针对这个诉求有没有啥好的方案。
感谢。

[Leslie Yuen]

 不知道理解错没有， 感觉你这个场景使用session windows能解决

sunfulin <[hidden email]> 于2020年10月30日周五 上午11:01写道：

> hi，community，
> 我最近有一个业务场景，需要基于消息流和具体的业务逻辑判断生成超时事件，考虑通过flink
> cep来实现。不过在这个场景中，需要针对输入的消息，判断如果一个小时内没有匹配的数据到来，就需要把该事件输出。
> 目前的cep机制，应该需要下一个事件消息到来时才会输出事件。想请教下各位大神，针对这个诉求有没有啥好的方案。
> 感谢。

[sunfulin]

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














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

[熊云昆]

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


| |
熊云昆
|
|
邮箱：[hidden email]
|

签名由 网易邮箱大师 定制

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



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














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