Class QueryableStoreProvider
- java.lang.Object
-
- org.apache.kafka.streams.state.internals.QueryableStoreProvider
-
public class QueryableStoreProvider extends java.lang.Object
A wrapper over all of theStateStoreProvider
s in a Topology
-
-
Constructor Summary
Constructors Constructor Description QueryableStoreProvider(java.util.List<StateStoreProvider> storeProviders, GlobalStateStoreProvider globalStateStoreProvider)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <T> T
getStore(java.lang.String storeName, QueryableStoreType<T> queryableStoreType)
Get a composite object wrapping the instances of theStateStore
with the provided storeName andQueryableStoreType
-
-
-
Constructor Detail
-
QueryableStoreProvider
public QueryableStoreProvider(java.util.List<StateStoreProvider> storeProviders, GlobalStateStoreProvider globalStateStoreProvider)
-
-
Method Detail
-
getStore
public <T> T getStore(java.lang.String storeName, QueryableStoreType<T> queryableStoreType)
Get a composite object wrapping the instances of theStateStore
with the provided storeName andQueryableStoreType
- Type Parameters:
T
- The expected type of the returned store- Parameters:
storeName
- name of the storequeryableStoreType
- accept stores passingQueryableStoreType.accepts(StateStore)
- Returns:
- A composite object that wraps the store instances.
-
-