pyflink.datastream.window.ContinuousProcessingTimeTrigger

class ContinuousProcessingTimeTrigger(interval: int)

A Trigger that continuously fires based on a given time interval as measured by the clock of the machine on which the job is running.

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.
of(interval)
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.
register_next_fire_timestamp(time, window, ...)