Class TimestampedKeyQuery<K,V>

java.lang.Object
org.apache.kafka.streams.query.TimestampedKeyQuery<K,V>
Type Parameters:
K - Type of keys
V - Type of values
All Implemented Interfaces:
Query<ValueAndTimestamp<V>>
@Evolving public final class TimestampedKeyQuery<K,V>extends Object implements Query<ValueAndTimestamp<V>>
Interactive query for retrieving a single record based on its key from TimestampedKeyValueStore

  • Method Details

    • withKey

      public static <K,V> TimestampedKeyQuery<K,V> withKey(K key)
      Creates a query that will retrieve the record identified by key if it exists (or null otherwise).
      Type Parameters:
      K - The type of the key
      V - The type of the value that will be retrieved
      Parameters:
      key - The key to retrieve

    • skipCache

      public TimestampedKeyQuery<K,V> skipCache()
      Specifies that the cache should be skipped during query evaluation. This means, that the query will always get forwarded to the underlying store.

    • key

      public K key()
      Return the key that was specified for this query.
      Returns:
      The key that was specified for this query.

    • isSkipCache

      public boolean isSkipCache()
      The flag whether to skip the cache or not during query evaluation.