Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-7384

Unify event and processing time handling in the AbstractKeyedCEPPatternOperator.

    Details

    • Type: Improvement
    • Status: Open
    • Priority: Minor
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: Library / CEP
    • Labels:
      None

      Description

      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.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                dawidwys Dawid Wysakowicz
                Reporter:
                kkl0u Kostas Kloudas
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated: