Package org.apache.kafka.streams.query
package org.apache.kafka.streams.query
-
ClassDescriptionThis enumeration type captures the various top-level reasons that a particular partition of a store would fail to execute a query.KeyQuery<K,
V> Interactive query for retrieving a single record based on its key.A representation of a position vector with respect to a set of topic partitions.A class bounding the processing statePositionduring queries.Query<R>Marker interface that all interactive queries must implement (seeKafkaStreams.query(StateQueryRequest)).Runtime configuration parametersQueryResult<R>Container for a single partition's result when executing aStateQueryRequest.RangeQuery<K,V> Interactive query for issuing range queries and scans over KeyValue stores.The request object for Interactive Queries.A progressive builder interface for creatingStoreQueryRequests.The response object for interactive queries.WindowKeyQuery<K,V> WindowRangeQuery<K,V>