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. pushedBackTimers are timers that were in completedTimers at the input, but were pushed back due to processing constraints.

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()
java.lang.String	toString()
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.
WatermarkManager.TimerUpdate	withPushedBackTimers(java.lang.Iterable<org.apache.beam.runners.core.TimerInternals.TimerData> pushedBackTimers) Returns a WatermarkManager.TimerUpdate that is like this one, but with the pushedBackTimersare removed set by provided pushedBackTimers.

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, 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. Note that if any of the completed timers is in pushedBackTimers, then it is set instead. The pushedBackTimers are cleared afterwards.

withPushedBackTimers

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

Returns a WatermarkManager.TimerUpdate that is like this one, but with the pushedBackTimersare removed set by provided pushedBackTimers.

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

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object