pyflink.datastream.window.ProcessingTimeTrigger#
- class ProcessingTimeTrigger[source]#
A Trigger that fires once the current system time passes the end of the window to which a pane belongs.
Methods
can_merge
()Note
If this returns true you must properly implement
on_merge()
clear
(window, ctx)Clears any state that the trigger might still hold for the given window.
create
()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.
on_merge
(window, ctx)Called when several windows have been merged into one window by the
WindowAssigner
.on_processing_time
(time, window, ctx)Called when a processing-time timer that was set using the trigger context fires.