com.google.cloud.dataflow.sdk.transforms.windowing

Class Trigger.OnceTrigger<W extends BoundedWindow>

java.lang.Object

com.google.cloud.dataflow.sdk.transforms.windowing.Trigger<W>

com.google.cloud.dataflow.sdk.transforms.windowing.Trigger.OnceTrigger<W>

Type Parameters:

W - BoundedWindow subclass used to represent the windows used by this AtMostOnceTrigger

All Implemented Interfaces:

java.io.Serializable

Direct Known Subclasses:

AfterAll, AfterFirst, AfterPane, TimeTrigger

Enclosing class:

Trigger<W extends BoundedWindow>

public abstract static class Trigger.OnceTrigger<W extends BoundedWindow>
extends Trigger<W>

Triggers that are guaranteed to fire at most once should extend from this, rather than the general Trigger class to indicate that behavior.

TODO: Add checks that an AtMostOnceTrigger never returns TriggerResult.FIRE.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class com.google.cloud.dataflow.sdk.transforms.windowing.Trigger

Trigger.OnceTrigger<W extends BoundedWindow>, Trigger.OnElementEvent<W>, Trigger.OnMergeEvent<W>, Trigger.OnTimerEvent<W extends BoundedWindow>, Trigger.TimeDomain, Trigger.TriggerContext<W extends BoundedWindow>, Trigger.TriggerId<W extends BoundedWindow>, Trigger.TriggerResult, Trigger.WindowStatus

Constructor Summary

Constructors

Constructor and Description
Trigger.OnceTrigger()

Method Summary

Methods inherited from class com.google.cloud.dataflow.sdk.transforms.windowing.Trigger

clear, getWatermarkCutoff, isCompatible, onElement, onMerge, onTimer, orFinally, willNeverFinish

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Trigger.OnceTrigger

public Trigger.OnceTrigger()