Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
languagejava
firstline1
titleKeyQuery.java
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.

...