See: Description
Interface | Description |
---|---|
Query<R> |
Marker interface that all interactive queries must implement (see
KafkaStreams.query(StateQueryRequest) ). |
QueryResult<R> |
Container for a single partition's result when executing a
StateQueryRequest . |
Class | Description |
---|---|
KeyQuery<K,V> |
Interactive query for retrieving a single record based on its key.
|
MultiVersionedKeyQuery<K,V> |
Interactive query for retrieving a set of records with the same specified key and different timestamps within the specified time range.
|
Position |
A representation of a position vector with respect to a set of topic partitions.
|
PositionBound |
A class bounding the processing state
Position during queries. |
QueryConfig |
Runtime configuration parameters
|
RangeQuery<K,V> |
Interactive query for issuing range queries and scans over KeyValue stores.
|
StateQueryRequest<R> |
The request object for Interactive Queries.
|
StateQueryRequest.InStore |
A progressive builder interface for creating
StoreQueryRequest s. |
StateQueryResult<R> |
The response object for interactive queries.
|
TimestampedKeyQuery<K,V> |
Interactive query for retrieving a single record based on its key from
TimestampedKeyValueStore |
TimestampedRangeQuery<K,V> |
Interactive query for issuing range queries and scans over
TimestampedKeyValueStore |
VersionedKeyQuery<K,V> |
Interactive query for retrieving a single record from a versioned state store based on its key and timestamp.
|
WindowKeyQuery<K,V> | |
WindowRangeQuery<K,V> |
Enum | Description |
---|---|
FailureReason |
This enumeration type captures the various top-level reasons that a particular
partition of a store would fail to execute a query.
|
ResultOrder |