AfterEach (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 AfterEach<W extends BoundedWindow>

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


    @Experimental(value=TRIGGER)
    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


이 페이지가 도움이 되었나요? 평가를 부탁드립니다.

다음에 대한 의견 보내기...

도움이 필요하시나요? 지원 페이지를 방문하세요.