Kostas Kloudas created FLINK-7384:
-------------------------------------
Summary: Unify event and processing time handling in the
AbstractKeyedCEPPatternOperator.
Key: FLINK-7384
URL: https://issues.apache.org/jira/browse/FLINK-7384
Project: Flink
Issue Type: Improvement
Components: CEP
Reporter: Kostas Kloudas
Assignee: Dawid Wysakowicz
Priority: Minor
Fix For: 1.4.0
With the recent changes introduced in
https://issues.apache.org/jira/browse/FLINK-7293, the code paths between event-
and processing-time handling are very close. This gives an opportunity to unify
the 2 paths.
To do this when operating in processing time, the user will specify an interval
(like the watermark interval in event time), during which elements will be
buffered, and only when this interval expires, the elements will be emitted.
This is the same as the case of event-time, where elements between watermarks
are buffered.
This change will remove the need to register a processing time timer for every
millisecond and it will also allow to emit timed-out patterns in processing
time without having to wait for the "next" element to arrive.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
