Package org.apache.kafka.streams.state

Class ValueAndTimestamp<V>

java.lang.Object
org.apache.kafka.streams.state.ValueAndTimestamp<V>
Type Parameters:
V -
public final class ValueAndTimestamp<V> extends Object
Combines a value from a KeyValue with a timestamp.

  • Method Details

    • make

      public static <V> ValueAndTimestamp<V> make(V value, long timestamp)
      Create a new ValueAndTimestamp instance if the provided value is not null.
      Type Parameters:
      V - the type of the value
      Parameters:
      value - the value
      timestamp - the timestamp
      Returns:
      a new ValueAndTimestamp instance if the provided value is not null; otherwise null is returned

    • makeAllowNullable

      public static <V> ValueAndTimestamp<V> makeAllowNullable(V value, long timestamp)
      Create a new ValueAndTimestamp instance. The provided value may be null.
      Type Parameters:
      V - the type of the value
      Parameters:
      value - the value
      timestamp - the timestamp
      Returns:
      a new ValueAndTimestamp instance

    • getValueOrNull

      public static <V> V getValueOrNull(ValueAndTimestamp<V> valueAndTimestamp)
      Return the wrapped value of the given valueAndTimestamp parameter if the parameter is not null.
      Type Parameters:
      V - the type of the value
      Parameters:
      valueAndTimestamp - a ValueAndTimestamp instance; can be null
      Returns:
      the wrapped value of valueAndTimestamp if not null; otherwise null

    • value

      public V value()

    • timestamp

      public long timestamp()

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object