org.apache.beam.runners.direct

Class WatermarkManager.FiredTimers<ExecutableT>

java.lang.Object

org.apache.beam.runners.direct.WatermarkManager.FiredTimers<ExecutableT>

Enclosing class:

WatermarkManager<ExecutableT,CollectionT>

public static class WatermarkManager.FiredTimers<ExecutableT>
extends java.lang.Object

A pair of 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.

Method Summary

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()

Methods inherited from class java.lang.Object

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

Method Detail

getExecutable

public ExecutableT getExecutable()

getKey

public StructuralKey<?> getKey()

getTimers

public java.util.Collection<org.apache.beam.runners.core.TimerInternals.TimerData> getTimers()

Gets all of the timers that have fired within the provided 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.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object