public static class Never.NeverTrigger extends Trigger.OnceTrigger
|Modifier and Type||Method and Description|
Subclasses should override this to return the
For internal use only; no backwards-compatibility guarantees.
equals, hashCode, isCompatible, orFinally, subTriggers, toString
protected Trigger getContinuationTrigger(java.util.List<Trigger> continuationTriggers)
Trigger. For convenience, this is provided the continuation trigger of each of the sub-triggers in the same order as
continuationTriggers- contains the result of
Trigger.getContinuationTrigger()on each of the
subTriggersin the same order.
public Instant getWatermarkThatGuaranteesFiring(BoundedWindow window)
Returns a bound in event time by which this trigger would have fired at least once for a given window had there been input data.
For triggers that do not fire based on the watermark advancing, returns
This estimate may be used, for example, to determine that there are no elements in a side-input window, which causes the default value to be used instead.