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:
java.io.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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(@Nullable java.lang.Object obj)
protected AfterWatermark.FromEndOfWindow
getContinuationTrigger(java.util.List<Trigger> continuationTriggers)
Subclasses should override this to return theTrigger.getContinuationTrigger()
of thisTrigger
.org.joda.time.Instant
getWatermarkThatGuaranteesFiring(BoundedWindow window)
For internal use only; no backwards-compatibility guarantees.int
hashCode()
java.lang.String
toString()
AfterWatermark.AfterWatermarkEarlyAndLate
withEarlyFirings(Trigger.OnceTrigger earlyFirings)
Creates a newTrigger
like the this, except that it fires repeatedly whenever the givenTrigger
fires before the watermark has passed the end of the window.AfterWatermark.AfterWatermarkEarlyAndLate
withLateFirings(Trigger.OnceTrigger lateFirings)
Creates a newTrigger
like the this, except that it fires repeatedly whenever the givenTrigger
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
-
-
-
-
Method Detail
-
withEarlyFirings
public AfterWatermark.AfterWatermarkEarlyAndLate withEarlyFirings(Trigger.OnceTrigger earlyFirings)
Creates a newTrigger
like the this, except that it fires repeatedly whenever the givenTrigger
fires before the watermark has passed the end of the window.
-
withLateFirings
public AfterWatermark.AfterWatermarkEarlyAndLate withLateFirings(Trigger.OnceTrigger lateFirings)
Creates a newTrigger
like the this, except that it fires repeatedly whenever the givenTrigger
fires after the watermark has passed the end of the window.
-
getWatermarkThatGuaranteesFiring
public org.joda.time.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 classTrigger
-
getContinuationTrigger
protected AfterWatermark.FromEndOfWindow getContinuationTrigger(java.util.List<Trigger> continuationTriggers)
Description copied from class:Trigger
Subclasses should override this to return theTrigger.getContinuationTrigger()
of thisTrigger
. For convenience, this is provided the continuation trigger of each of the sub-triggers in the same order asTrigger.subTriggers
.- Specified by:
getContinuationTrigger
in classTrigger
- Parameters:
continuationTriggers
- contains the result ofTrigger.getContinuationTrigger()
on each of thesubTriggers
in the same order.
-
-