[FLINK-13881] CEP within method should applied in every independent pattern

• Type: Improvement
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Affects Version/s: 1.9.0
• Component/s: Library / CEP
• Labels: auto-deprioritized-major auto-deprioritized-minor
• Assignee: Unassigned
• Reporter: YufeiLiu
• Created: 28/Aug/19 07:49
• Updated: 22/Nov/21 22:38

Description

When I write a Pattern like this:

Pattern.begin("start").where()
  .followBy("middle0").where().within(Time.second(1))
  .followBy("middle1").where().within(Time.second(2))
  .followBy("middle2").where().within(Time.second(3))

the actual within time is the smallest: 1 second.

I created a TimeCondition extends IterativeCondition, and I can get timestamp of current event and previous computation state, then I compare them in condition filter. Also make some change in NFACompiler, transform within as StateTransition rather than a gobal property "windowTime" of NFA.
It could work, but I dont know should I change the implementation of within or create another syntax.
dawidwys Is this meaningful?

Issue Links

• is related to: FLINK-16011 Normalize the within usage in Pattern