org.apache.beam.runners.direct

Class WatermarkManager.TimerUpdate

java.lang.Object

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

Enclosing class:

WatermarkManager<ExecutableT,CollectionT>

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

A collection of newly set, deleted, and completed timers.

setTimers and deletedTimers are collections of TimerInternals.TimerData that have been added to the TimerInternals of an executed step. completedTimers are timers that were delivered as the input to the executed step.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	WatermarkManager.TimerUpdate.TimerUpdateBuilder A WatermarkManager.TimerUpdate builder that needs to be provided with set timers and deleted timers.

Method Summary

Modifier and Type	Method and Description
static WatermarkManager.TimerUpdate.TimerUpdateBuilder	builder(StructuralKey<?> key) Creates a new WatermarkManager.TimerUpdate builder with the provided completed timers that needs the set and deleted timers to be added to it.
static WatermarkManager.TimerUpdate	empty() Returns a TimerUpdate for a null key with no timers.
boolean	equals(java.lang.Object other)
java.lang.Iterable<? extends org.apache.beam.runners.core.TimerInternals.TimerData>	getCompletedTimers()
java.lang.Iterable<? extends org.apache.beam.runners.core.TimerInternals.TimerData>	getDeletedTimers()
java.lang.Iterable<? extends org.apache.beam.runners.core.TimerInternals.TimerData>	getSetTimers()
int	hashCode()
WatermarkManager.TimerUpdate	withCompletedTimers(java.lang.Iterable<org.apache.beam.runners.core.TimerInternals.TimerData> completedTimers) Returns a WatermarkManager.TimerUpdate that is like this one, but with the specified completed timers.

Methods inherited from class java.lang.Object

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

Method Detail

empty

public static WatermarkManager.TimerUpdate empty()

Returns a TimerUpdate for a null key with no timers.

builder

public static WatermarkManager.TimerUpdate.TimerUpdateBuilder builder(StructuralKey<?> key)

Creates a new WatermarkManager.TimerUpdate builder with the provided completed timers that needs the set and deleted timers to be added to it.

getCompletedTimers

public java.lang.Iterable<? extends org.apache.beam.runners.core.TimerInternals.TimerData> getCompletedTimers()

getSetTimers

public java.lang.Iterable<? extends org.apache.beam.runners.core.TimerInternals.TimerData> getSetTimers()

getDeletedTimers

public java.lang.Iterable<? extends org.apache.beam.runners.core.TimerInternals.TimerData> getDeletedTimers()

withCompletedTimers

public WatermarkManager.TimerUpdate withCompletedTimers(java.lang.Iterable<org.apache.beam.runners.core.TimerInternals.TimerData> completedTimers)

Returns a WatermarkManager.TimerUpdate that is like this one, but with the specified completed timers.

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object other)

Overrides:

equals in class java.lang.Object