Details
-
Improvement
-
Status: Open
-
Not a Priority
-
Resolution: Unresolved
-
1.9.0
-
None
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?
Attachments
Issue Links
- is related to
-
FLINK-16011 Normalize the within usage in Pattern
- Resolved