public static final class WatermarkManager.TimerUpdate.TimerUpdateBuilder
extends java.lang.Object
WatermarkManager.TimerUpdate
builder that needs to be provided with set timers and deleted timers.Modifier and Type | Method and Description |
---|---|
WatermarkManager.TimerUpdate |
build()
Returns a new
WatermarkManager.TimerUpdate with the most recently set completedTimers, setTimers,
and deletedTimers. |
WatermarkManager.TimerUpdate.TimerUpdateBuilder |
deletedTimer(org.apache.beam.runners.core.TimerInternals.TimerData deletedTimer)
Adds the provided timer to the collection of deleted timers, removing it from set timers if
it has previously been set.
|
WatermarkManager.TimerUpdate.TimerUpdateBuilder |
setTimer(org.apache.beam.runners.core.TimerInternals.TimerData setTimer)
Adds the provided timer to the collection of set timers, removing it from deleted timers if
it has previously been deleted.
|
WatermarkManager.TimerUpdate.TimerUpdateBuilder |
withCompletedTimers(java.lang.Iterable<org.apache.beam.runners.core.TimerInternals.TimerData> completedTimers)
Adds all of the provided timers to the collection of completed timers, and returns this
WatermarkManager.TimerUpdate.TimerUpdateBuilder . |
public WatermarkManager.TimerUpdate.TimerUpdateBuilder withCompletedTimers(java.lang.Iterable<org.apache.beam.runners.core.TimerInternals.TimerData> completedTimers)
WatermarkManager.TimerUpdate.TimerUpdateBuilder
.public WatermarkManager.TimerUpdate.TimerUpdateBuilder setTimer(org.apache.beam.runners.core.TimerInternals.TimerData setTimer)
WatermarkManager.TimerUpdate.TimerUpdateBuilder
.public WatermarkManager.TimerUpdate.TimerUpdateBuilder deletedTimer(org.apache.beam.runners.core.TimerInternals.TimerData deletedTimer)
WatermarkManager.TimerUpdate.TimerUpdateBuilder
.public WatermarkManager.TimerUpdate build()
WatermarkManager.TimerUpdate
with the most recently set completedTimers, setTimers,
and deletedTimers.