[FLINK-9431] Introduce TimeEnd State to flink cep

• Type: Improvement
• Status: Closed
• Priority: Not a Priority
• Resolution: Duplicate
• Affects Version/s: 1.4.2
• Component/s: Library / CEP
• Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned pull-request-available
• Assignee: Unassigned
• Reporter: WenJun Min
• Created: 24/May/18 09:43
• Updated: 17/Jun/22 01:15
• Resolved: 17/Jun/22 01:15

Description

Now flink cep have no support to reach a Final State upon past some time. if i use a pattern like

Pattern.begin('A').notFollowedBy("B")

, 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

Pattern.begin('A').notFollowedBy("B").timeEnd("end").

,
dawidwys kkl0u Is this meaningful?

Issue Links

• duplicates: FLINK-26941 Support Pattern end with notFollowedBy with window
• links to: GitHub Pull Request #6234
• links to: GitHub Pull Request #6234