[ https://issues.apache.org/jira/browse/FLINK-9431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16488734#comment-16488734 ]
aitozi edited comment on FLINK-9431 at 5/24/18 9:56 AM: -------------------------------------------------------- [~dawidwys] Three thing: # if i use {code:java}Pattern.begin('A').notfollowedBy("B").within(Time.minutes(5)){code}, Pattern cant be end with notFollowedBy # within just compare the time with the start state, not with the any middle pattern you refer to. May be you want express the {code:java}A followedBy B notFollowedBy C and emit (A, B) when 5 minutes past{code} # it is not directly, i have to get matched results from timeout results I think timeEnd state only need to work with notFollowedBy pattern because it has a explict path to Final state, and timeEnd state can reach Final when time past. was (Author: aitozi): [~dawidwys] Three thing: # 1. if i use {code:java}Pattern.begin('A').notfollowedBy("B").within(Time.minutes(5)){code}, Pattern cant be end with notFollowedBy # 2. within just compare the time with the start state, not with the any middle pattern you refer to. May be you want express the {code:java}A followedBy B notFollowedBy C and emit (A, B) when 5 minutes past{code} # 3. it is not directly, i have to get matched results from timeout results I think timeEnd state only need to work with notFollowedBy pattern because it has a explict path to Final state, and timeEnd state can reach Final when time past. > Introduce TimeEnd State to flink cep > ------------------------------------ > > Key: FLINK-9431 > URL: https://issues.apache.org/jira/browse/FLINK-9431 > Project: Flink > Issue Type: Improvement > Components: CEP > Affects Versions: 1.4.2 > Reporter: aitozi > Assignee: aitozi > Priority: Major > > 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)