Package io.streamthoughts.azkarra.api.query
-
Interface Summary Interface Description LocalStoreAccessor.StoreSupplier<T> LocalStoreQuery<K,V> Default interface to execute a local state storeName.RemoteQueryClient Default interface to query a remote streams state store. -
Class Summary Class Description DistributedQuery<K,V> Default class to query a state store either locally, remotely or globally.LocalStoreAccessor<T> Default class to wrap access to local state store.Queried QueryInfo Class which is use to wrap information about the store to be query.QueryParams -
Enum Summary Enum Description StoreOperation StoreType The store types supported byKafkaStreams.