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

Modifier and Type	Method and Description
TriggerBuilder<W>	withLateFirings(Trigger.OnceTrigger<W> lateTrigger) Creates a new Trigger like the this, except that it fires repeatedly whenever the given Trigger fires before 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 new Trigger like the this, except that it fires repeatedly whenever the given Trigger fires before the watermark has passed the end of the window.