Package org.apache.beam.sdk.transforms.windowing

Class AfterWatermark.AfterWatermarkEarlyAndLate

java.lang.Object

org.apache.beam.sdk.transforms.windowing.Trigger

org.apache.beam.sdk.transforms.windowing.AfterWatermark.AfterWatermarkEarlyAndLate

All Implemented Interfaces:

Serializable

Enclosing class:

AfterWatermark

public static class AfterWatermark.AfterWatermarkEarlyAndLate
extends Trigger

See AfterWatermark.

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.beam.sdk.transforms.windowing.Trigger

Trigger.OnceTrigger

Field Summary

Fields inherited from class org.apache.beam.sdk.transforms.windowing.Trigger

subTriggers

Method Summary

Modifier and Type	Method	Description
<OutputT> OutputT	accept(TriggerVisitor<OutputT> visitor)
Trigger	getContinuationTrigger()	Return a trigger to use after a GroupByKey to preserve the intention of this trigger.
protected Trigger	getContinuationTrigger(List<Trigger> continuationTriggers)	Subclasses should override this to return the Trigger.getContinuationTrigger() of this Trigger.
Trigger.OnceTrigger	getEarlyTrigger()
Trigger.OnceTrigger	getLateTrigger()
Instant	getWatermarkThatGuaranteesFiring(BoundedWindow window)	For internal use only; no backwards-compatibility guarantees.
boolean	mayFinish()	Returns true if there is no late firing set up, otherwise false.
String	toString()
AfterWatermark.AfterWatermarkEarlyAndLate	withEarlyFirings(Trigger.OnceTrigger earlyTrigger)
AfterWatermark.AfterWatermarkEarlyAndLate	withLateFirings(Trigger.OnceTrigger lateTrigger)

Methods inherited from class org.apache.beam.sdk.transforms.windowing.Trigger

equals, hashCode, isCompatible, orFinally, subTriggers

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Details

getEarlyTrigger

public Trigger.OnceTrigger getEarlyTrigger()

getLateTrigger

public Trigger.OnceTrigger getLateTrigger()

withEarlyFirings

public AfterWatermark.AfterWatermarkEarlyAndLate withEarlyFirings(Trigger.OnceTrigger earlyTrigger)

withLateFirings

public AfterWatermark.AfterWatermarkEarlyAndLate withLateFirings(Trigger.OnceTrigger lateTrigger)

accept

public <OutputT> OutputT accept(TriggerVisitor<OutputT> visitor)

Specified by:

accept in class Trigger

getContinuationTrigger

public Trigger getContinuationTrigger()

Description copied from class: Trigger

Return a trigger to use after a GroupByKey to 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.

Overrides:

getContinuationTrigger in class Trigger

getContinuationTrigger

protected Trigger getContinuationTrigger(List<Trigger> continuationTriggers)

Description copied from class: Trigger

Subclasses should override this to return the Trigger.getContinuationTrigger() of this Trigger. For convenience, this is provided the continuation trigger of each of the sub-triggers in the same order as Trigger.subTriggers.

Specified by:

getContinuationTrigger in class Trigger

Parameters:

continuationTriggers - contains the result of Trigger.getContinuationTrigger() on each of the subTriggers in the same order.

getWatermarkThatGuaranteesFiring

public Instant getWatermarkThatGuaranteesFiring(BoundedWindow window)

Description copied from class: Trigger

For internal use only; no backwards-compatibility guarantees.

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 BoundedWindow.TIMESTAMP_MAX_VALUE.

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.

Specified by:

getWatermarkThatGuaranteesFiring in class Trigger

mayFinish

public boolean mayFinish()

Returns true if there is no late firing set up, otherwise false.

Specified by:

mayFinish in class Trigger

toString

public String toString()

Overrides:

toString in class Trigger