Module query 

IQv2 query objects. Each builder lowers to a store::iq::Iq2Query with no serde, and the store supplies the actual serdes.

Structs

KeyQuery

Single-key lookup. Result: Option<V>.

MultiVersionedKeyQuery

All versions of a key whose validity overlaps [from_time, to_time] (KIP-968). A None bound is unbounded on that side. The order is ascending by valid_from, unless you call with_descending_timestamps(). Result: Vec<VersionedRecord<V>>.

RangeQuery

Key-range scan. A None bound is unbounded on that side. Result: Vec<(K,V)>.

VersionedKeyQuery

Single versioned-key lookup (KIP-960). as_of = None gives the latest live version. Result: Option<VersionedRecord<V>>.

WindowKeyQuery

One key, window starts in [from_time, to_time]. Result: Vec<(i64, V)>.

WindowRangeQuery

Key range by window-start range. Result: Vec<((K, i64), V)>.

Traits

Query

A typed IQv2 query. Result is the type that KafkaStreams::query returns per partition. This trait is sealed, so only the in-crate query types implement it.