Google Cloud Dataflow SDK for Java, version 1.9.1
Interface AfterWatermark.AfterWatermarkEarly<W extends BoundedWindow>
All Methods Instance Methods Abstract Methods Modifier and Type Method and Description
withLateFirings(Trigger.OnceTrigger<W> lateTrigger)Creates a new
Triggerlike the this, except that it fires repeatedly whenever the given
Triggerfires after the watermark has passed the end of the window.