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:

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.

See Also:

Serialized Form

Nested Class Summary

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

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

Field Summary

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

subTriggers

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Trigger.OnceTrigger(List<Trigger<W>> subTriggers)

Method Summary

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

clear, getWatermarkThatGuaranteesFiring, isCompatible, onElement, onMerge, onTimer, orFinally, subTriggers, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

Trigger.OnceTrigger

protected Trigger.OnceTrigger(List<Trigger<W>> subTriggers)