[jira] [Commented] (FLINK-9431) Introduce TimeEnd State to flink cep

["Dawid Wysakowicz (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-9431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832337#comment-16832337 ] 

Dawid Wysakowicz commented on FLINK-9431:
-----------------------------------------

Hi [~aitozi],
First of all I am really sorry for a very late reply. I think the described problem is something we should think about at some point and provide some way of completing patterns based on time constraint. That said though I am not sure if the suggested API is the best we can come up with. This is a completely new feature that was not described nor discussed in any of the documents or papers that we used when implementing the CEP library. Moreover it changes the behavior of the state machine, what makes it quite invasive. Therefore I think it requires a good discussion in the community first. 

Another idea is you could try putting a fork of the CEP library in the upcoming [community hub|https://lists.apache.org/thread.html/21cc3f4e5de5c40fa86547b0e4c544ec91cf8e5782c1cc43543d18dd@%3Cdev.flink.apache.org%3E] to gather feedback from the users first? What do you think?

> Introduce TimeEnd State to flink cep
> ------------------------------------
>
>                 Key: FLINK-9431
>                 URL: https://issues.apache.org/jira/browse/FLINK-9431
>             Project: Flink
>          Issue Type: Improvement
>          Components: Library / CEP
>    Affects Versions: 1.4.2
>            Reporter: aitozi
>            Assignee: aitozi
>            Priority: Major
>              Labels: pull-request-available
>
> Now flink cep have no support to reach a Final State upon past some time. if i use a pattern like 
> {code:java}Pattern.begin('A').notFollowedBy("B"){code}, if i want A element be emitted after 5minutes, i have no way.
> I want to introduce a timeEnd State to work with notFollowedBy to figure out with this scenior.
> It can be used like this {code:java}Pattern.begin('A').notFollowedBy("B").timeEnd("end").{code},
> [~dawidwys] [~kkl0u] Is this meaningful?



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)