Google Cloud Dataflow SDK for Java, version 1.9.1
com.google.cloud.dataflow.sdk.transforms.windowing
Interface AfterWatermark.AfterWatermarkEarly<W extends BoundedWindow>
-
- All Superinterfaces:
- TriggerBuilder<W>
- Enclosing class:
- AfterWatermark<W extends BoundedWindow>
public static interface AfterWatermark.AfterWatermarkEarly<W extends BoundedWindow> extends TriggerBuilder<W>
Interface for building an AfterWatermarkTrigger with early firings already filled in.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method and Description TriggerBuilder<W>
withLateFirings(Trigger.OnceTrigger<W> lateTrigger)
Creates a newTrigger
like the this, except that it fires repeatedly whenever the givenTrigger
fires after the watermark has passed the end of the window.-
Methods inherited from interface com.google.cloud.dataflow.sdk.transforms.windowing.TriggerBuilder
buildTrigger
-
-
-
-
Method Detail
-
withLateFirings
TriggerBuilder<W> withLateFirings(Trigger.OnceTrigger<W> lateTrigger)
Creates a newTrigger
like the this, except that it fires repeatedly whenever the givenTrigger
fires after the watermark has passed the end of the window.
-
-