Class ProcessingTimeTriggers


  • public class ProcessingTimeTriggers
    extends Object
    A Trigger that reacts to processing-time timers. The behavior can be one of the following:
    • fire when the processing time passes the end of the window (afterEndOfWindow()),
    • fire when the processing time advances by a certain interval after reception of the first element after the last firing for a given window (every(Duration)).

    In the first case, the trigger can also specify an early trigger. The early trigger will be responsible for specifying when the trigger should fire in the period between the beginning of the window and the time when the processing time passes the end of the window.