Package org.apache.beam.runners.spark.util

Class TimerUtils.TimerMarker

java.lang.Object

org.apache.beam.runners.spark.util.TimerUtils.TimerMarker

All Implemented Interfaces:

Serializable

Enclosing class:

TimerUtils

public static class TimerUtils.TimerMarker
extends Object
implements Serializable

A marker class used to identify timer keys and values in Spark transformations. Helps distinguish between regular data flow elements and timer events.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
TimerMarker()

Method Summary

Modifier and Type	Method	Description
boolean	equals(@Nullable Object o)
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

TimerMarker

public TimerMarker()

Method Details

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(@Nullable Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object