org.apache.beam.sdk.values

Class TimestampedValue<V>

java.lang.Object

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

Type Parameters:

V - the type of the value

public class TimestampedValue<V>
extends java.lang.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 and Description
static class	TimestampedValue.TimestampedValueCoder<T> A Coder for TimestampedValue.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
static <V> TimestampedValue<V>	atMinimumTimestamp(V value) Returns a new TimestampedValue with the minimum timestamp.
boolean	equals(java.lang.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.
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

TimestampedValue

protected TimestampedValue(@Nullable
                           V value,
                           Instant timestamp)

Method Detail

atMinimumTimestamp

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

Returns a new TimestampedValue with the minimum timestamp.

of

public static <V> TimestampedValue<V> of(@Nullable
                                         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(java.lang.Object other)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object