[jira] [Created] (FLINK-7384) Unify event and processing time handling in the AbstractKeyedCEPPatternOperator.

["Kostas Kloudas (JIRA)" <ji...@apache.org>]

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)