pyflink.datastream.window.TriggerResult

class TriggerResult(value)

Result type for trigger methods. This determines what happens with the window, for example whether the window function should be called, or the window should be discarded.

If a Trigger returns TriggerResult.FIRE or TriggerResult.FIRE_AND_PURGE but the window does not contain any data the window function will not be invoked, i.e. no data will be produced for the window.

• CONTINUE: No action is taken on the window.

• FIRE_AND_PURGE: Evaluates the window function and emits the ‘window result’.

• FIRE: On FIRE, the window is evaluated and results are emitted. The window is not purged

  though, all elements are retained.

• PURGE: All elements in the window are cleared and the window is discarded, without

  evaluating the window function or emitting any elements.

Methods

is_fire()
is_purge()

Attributes

CONTINUE
FIRE_AND_PURGE
FIRE
PURGE