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