[
https://issues.apache.org/jira/browse/FLINK-7384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantin Knauf updated FLINK-7384:
------------------------------------
Labels: pull-request-available (was: auto-closed pull-request-available)
Priority: Not a Priority (was: Minor)
> 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: Library / CEP
> Reporter: Kostas Kloudas
> Priority: Not a Priority
> Labels: pull-request-available
> Time Spent: 10m
> Remaining Estimate: 0h
>
> 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
(v8.3.4#803005)
