flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Kostas Kloudas (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-7384) Unify event and processing time handling in the AbstractKeyedCEPPatternOperator.
Date Mon, 07 Aug 2017 16:44:00 GMT
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)

Mime
View raw message