Package io.streamthoughts.azkarra.api.query
-
Interface Summary Interface Description InteractiveQueryService AInteractiveQueryService
can be used to query aKafkaStreams
state store.LocalExecutableQuery<K,V> Default interface to execute a local state storeName.LocalExecutableQueryWithKey<K1,K2,V> LocalPreparedQuery<K,V> ALocalStoreQueryBuilder
is used to build newLocalExecutableQuery
.LocalStoreAccessor.StoreSupplier<T> LocalStoreAccessProvider Query QueryableKafkaStreams QueryCall<K,V> AQueryCall
is a query that has been prepared for execution.QueryCall.QueryCallFactory AQueryCallFactory
is used to create newQueryCall
.QueryParams -
Class Summary Class Description DecorateQuery<T extends Query> GenericQueryParams LocalPreparedQuery.MissingRequiredKeyError LocalStoreAccessor<T> Default class to wrap access to local state store.LoggingFailureLocalExecutableQuery<K,V> QueryOptions TheQueryOptions
cane be used to set the options to be used for querying a state store.QueryRequest Class which is use to wrap information about the store to be query. -
Enum Summary Enum Description StoreOperation StoreType The store types supported byKafkaStreams
.