org.apache.kafka.streams.query

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

@InterfaceStability.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 Summary

Modifier and Type	Method and Description
boolean	isSkipCache() The flag whether to skip the cache or not during query evaluation.
K	key() Return the key that was specified for this query.
TimestampedKeyQuery<K,V>	skipCache() Specifies that the cache should be skipped during query evaluation.
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).

Methods inherited from class java.lang.Object

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

Method Detail

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.