|Modifier||Constructor and Description|
|Modifier and Type||Method and Description|
Return a trigger to use after a
equals, getContinuationTrigger, getWatermarkThatGuaranteesFiring, hashCode, isCompatible, orFinally, subTriggers, toString
protected OnceTrigger(@Nullable java.util.List<Trigger> subTriggers)
public final Trigger.OnceTrigger getContinuationTrigger()
GroupByKeyto preserve the intention of this trigger. Specifically, triggers that are time based and intended to provide speculative results should continue providing speculative results. Triggers that fire once (or multiple times) should continue firing once (or multiple times).
If this method is not overridden, its default implementation delegates its behavior to
Trigger.getContinuationTrigger(List) which is expected to be implemented by subclasses.