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(@Nullable 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(V value,
                           Instant timestamp)

Method Detail

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 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