AfterEach (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

Class AfterEach<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 AfterEach<W extends BoundedWindow>
    extends Trigger<W>
    A composite Trigger that executes its sub-triggers in order. Only one sub-trigger is executing at a time, and any time it fires the AfterEach fires. When the currently executing sub-trigger finishes, the AfterEach starts executing the next sub-trigger.

    AfterEach.inOrder(t1, t2, ...) finishes when all of the sub-triggers have finished.

    The following properties hold:

    • AfterEach.inOrder(AfterEach.inOrder(a, b), c) behaves the same as AfterEach.inOrder(a, b, c) and AfterEach.inOrder(a, AfterEach.inOrder(b, c).
    • AfterEach.inOrder(Repeatedly.forever(a), b) behaves the same as Repeatedly.forever(a), since the repeated trigger never finishes.

    See Also:
    Serialized Form