- class PurgingTrigger(nested_trigger: pyflink.datastream.window.Trigger[pyflink.datastream.window.T, pyflink.datastream.window.Window])[source]#
A trigger that can turn any Trigger into a purging Trigger. When the nested trigger fires, this will return a FIRE_AND_PURGE TriggerResult.
If this returns true you must properly implement
Clears any state that the trigger might still hold for the given window.
on_element(element, timestamp, window, ctx)
Called for every element that gets added to a pane.
on_event_time(time, window, ctx)
Called when an event-time timer that was set using the trigger context fires.
Called when several windows have been merged into one window by the
on_processing_time(time, window, ctx)
Called when a processing-time timer that was set using the trigger context fires.