Repeatedly (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

com.google.cloud.dataflow.sdk.transforms.windowing

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(AfterWatermark.isPastEndOfWindow());
      

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

    See Also:
    Serialized Form


Was this page helpful? Let us know how we did:

Send feedback about...

Cloud Dataflow