TimestampedValue (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

Warning: Dataflow SDK 1.x for Java is unsupported as of October 16, 2018. See Migrating from Dataflow SDK 1.x for Java for migration guidance.

Note: If you are using Cloud Dataflow SDK version 2.x, see the Apache Beam API reference documentation.

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

    All Methods Static Methods Instance Methods Concrete Methods 

    Modifier and Type	Method and Description
    boolean	equals(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 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()

    • equals

      public boolean equals(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