Repeatedly (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

Class Repeatedly<W extends BoundedWindow>

  • Type Parameters:
    W - BoundedWindow subclass used to represent the windows used by this Trigger
    All Implemented Interfaces:
    TriggerBuilder<W>, Serializable

    public class Repeatedly<W extends BoundedWindow>
    extends Trigger<W>
    Repeat a trigger, either until some condition is met or forever.

    For example, to fire after the end of the window, and every time late data arrives:


    Repeatedly.forever(someTrigger) behaves like an infinite AfterEach.inOrder(someTrigger, someTrigger, someTrigger, ...).

    See Also:
    Serialized Form