...
Code Block | ||||||
---|---|---|---|---|---|---|
| ||||||
package org.apache.kafka.streams.query;
/**
* Specifies the upper inclusive bound for the key query. The key query returns the record
* with the greatest timestamp <= asOfTimestamp
* @param asOfTimestamp The upper inclusive bound for timestamp
* @throws RuntimeException if the query already has a specified asOfTimestamp.
*/
public KeyQuery<K, V> asOf(Instant asOfTimestamp);
/**
* The timestamp of the query, if specified
*/
public Optional<Instant> getAsOfTimestamp() {
return asOfTimestamp;
} |
Examples....
The following example illustrates the use of the VersionedKeyQuery class to query a versioned state store.
...