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

Class AfterWatermark.FromEndOfWindow

java.lang.Object

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

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

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

All Implemented Interfaces:

Serializable

Enclosing class:

AfterWatermark

public static class AfterWatermark.FromEndOfWindow
extends Trigger.OnceTrigger

A watermark trigger targeted relative to the end of the window.

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
boolean	equals(@Nullable Object obj)
protected AfterWatermark.FromEndOfWindow	getContinuationTrigger(List<Trigger> continuationTriggers)	Subclasses should override this to return the Trigger.getContinuationTrigger() of this Trigger.
Instant	getWatermarkThatGuaranteesFiring(BoundedWindow window)	For internal use only; no backwards-compatibility guarantees.
int	hashCode()
String	toString()
AfterWatermark.AfterWatermarkEarlyAndLate	withEarlyFirings(Trigger.OnceTrigger earlyFirings)	Creates a new Trigger like the this, except that it fires repeatedly whenever the given Trigger fires before the watermark has passed the end of the window.
AfterWatermark.AfterWatermarkEarlyAndLate	withLateFirings(Trigger.OnceTrigger lateFirings)	Creates a new Trigger like the this, except that it fires repeatedly whenever the given Trigger fires after the watermark has passed the end of the window.

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

getContinuationTrigger, mayFinish

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

isCompatible, orFinally, subTriggers

Methods inherited from class java.lang.Object

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

Method Details

withEarlyFirings

public AfterWatermark.AfterWatermarkEarlyAndLate withEarlyFirings(Trigger.OnceTrigger earlyFirings)

Creates a new Trigger like the this, except that it fires repeatedly whenever the given Trigger fires before the watermark has passed the end of the window.

withLateFirings

public AfterWatermark.AfterWatermarkEarlyAndLate withLateFirings(Trigger.OnceTrigger lateFirings)

Creates a new Trigger like the this, except that it fires repeatedly whenever the given Trigger fires after the watermark has passed the end of the window.

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

getContinuationTrigger

protected AfterWatermark.FromEndOfWindow 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.

toString

public String toString()

Overrides:

toString in class Trigger

equals

public boolean equals(@Nullable Object obj)

Overrides:

equals in class Trigger

hashCode

public int hashCode()

Overrides:

hashCode in class Trigger