org.apache.beam.runners.direct

Class WatermarkManager.TimerUpdate.TimerUpdateBuilder

java.lang.Object

org.apache.beam.runners.direct.WatermarkManager.TimerUpdate.TimerUpdateBuilder

Enclosing class:

WatermarkManager.TimerUpdate

public static final class WatermarkManager.TimerUpdate.TimerUpdateBuilder
extends java.lang.Object

A WatermarkManager.TimerUpdate builder that needs to be provided with set timers and deleted timers.

Method Summary

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.

Methods inherited from class java.lang.Object

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

Method Detail

withCompletedTimers

public 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.

setTimer

public 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. Returns this WatermarkManager.TimerUpdate.TimerUpdateBuilder.

deletedTimer

public 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. Returns this WatermarkManager.TimerUpdate.TimerUpdateBuilder.

build

public WatermarkManager.TimerUpdate build()

Returns a new WatermarkManager.TimerUpdate with the most recently set completedTimers, setTimers, and deletedTimers.