Package org.apache.beam.sdk.values

Class TimestampedValue<V extends @Nullable Object>

java.lang.Object

org.apache.beam.sdk.values.TimestampedValue<V>

Type Parameters:

V - the type of the value

public class TimestampedValue<V extends @Nullable Object>
extends Object

An immutable pair of a value and a timestamp.

The timestamp of a value determines many properties, such as its assignment to windows and whether the value is late (with respect to the watermark of a PCollection).

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TimestampedValue.TimestampedValueCoder<T>	A Coder for TimestampedValue.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	TimestampedValue(V value, Instant timestamp)

Method Summary

Modifier and Type	Method	Description
static <V> TimestampedValue<V>	atMinimumTimestamp(V value)	Returns a new TimestampedValue with the minimum timestamp.
boolean	equals(@Nullable Object other)
Instant	getTimestamp()
V	getValue()
int	hashCode()
static <V> TimestampedValue<V>	of(V value, Instant timestamp)	Returns a new TimestampedValue with the given value and timestamp.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

TimestampedValue

protected TimestampedValue(V value,
 Instant timestamp)

Method Details

atMinimumTimestamp

public static <V> TimestampedValue<V> atMinimumTimestamp(V value)

Returns a new TimestampedValue with the minimum timestamp.

of

public static <V> TimestampedValue<V> of(V value,
 Instant timestamp)

Returns a new TimestampedValue with the given value and timestamp.

getValue

public V getValue()

getTimestamp

public Instant getTimestamp()

equals

public boolean equals(@Nullable Object other)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object