[
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)
