public static class WatermarkManager.FiredTimers<ExecutableT>
extends java.lang.Object
TimerInternals.TimerData
and key which can be delivered to the appropriate AppliedPTransform
. A timer fires at the executable that set it with a specific key when the
time domain in which it lives progresses past a specified time, as determined by the WatermarkManager
.Modifier and Type | Method and Description |
---|---|
ExecutableT |
getExecutable() |
StructuralKey<?> |
getKey() |
java.util.Collection<org.apache.beam.runners.core.TimerInternals.TimerData> |
getTimers()
Gets all of the timers that have fired within the provided
TimeDomain . |
java.lang.String |
toString() |
public ExecutableT getExecutable()
public StructuralKey<?> getKey()
public java.util.Collection<org.apache.beam.runners.core.TimerInternals.TimerData> getTimers()
TimeDomain
. If no timers
fired within the provided domain, return an empty collection.
Timers within a TimeDomain
are guaranteed to be in order of increasing timestamp.
public java.lang.String toString()
toString
in class java.lang.Object