Versions Compared

Old Version 2

changes.mady.by.user Kostas Kloudas

Saved on

compared with

New Version 3

changes.mady.by.user Kostas Kloudas

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

This page is meant as a template for writing a FLIP. To create a FLIP choose Tools->Copy on this page and modify with your content and replace the heading with the next FLIP number and a description of your issue. Replace anything in italics with your own description.

Status

Current state: "Under Discussion"

...

JIRA: here (<- link to https://issues.apache.org/jira/browse/FLINK-XXXX)
Released: <Flink Version>

Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).

...

The triggers currently offered by Apache Flink are:

  • CountTrigger(threshold)(non-purging): Fires after the number of elements in a window passes the given threshold.

  • EventTimeTrigger()(purging): Fire after the watermark passes the end of a window.

  • ProcessingTimeTrigger() (purging): Fire after processing time passes the end of a window.

  • ContinuousEventTimeTrigger(interval)(non-purging): Fire repeatedly with a given periodicity according to the watermark.

  • ContinuousProcessingTimeTrigger(interval)(non-purging): Fire repeatedly with a given periodicity according to processing time.

  • DeltaTrigger(delta-function)(non-purging): Fire once the delta between a start-value and the newly added value exceeds a given threshold.

  • PurgingTrigger(trigger)(purging): Turns any trigger into a purging trigger.

Limitations of the current triggers:

...