com.google.cloud.dataflow.sdk.values

Class TimestampedValue<V>

java.lang.Object

com.google.cloud.dataflow.sdk.values.TimestampedValue<V>

Type Parameters:

V - the type of the value

public class TimestampedValue<V>
extends java.lang.Object

An immutable (value, timestamp) pair.

Used for assigning initial timestamps to values inserted into a pipeline with Create.timestamped(java.lang.Iterable<com.google.cloud.dataflow.sdk.values.TimestampedValue<T>>).

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
Instant	getTimestamp()
V	getValue()
static <V> TimestampedValue<V>	of(V value, Instant timestamp) Returns a new TimestampedValue with the given value and timestamp.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TimestampedValue

protected TimestampedValue(V value,
                Instant timestamp)

Method Detail

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