public class QueryableStoreProvider
extends java.lang.Object
StateStoreProvider
s in a TopologyConstructor and Description |
---|
QueryableStoreProvider(java.util.List<StateStoreProvider> storeProviders,
GlobalStateStoreProvider globalStateStoreProvider) |
Modifier and Type | Method and Description |
---|---|
<T> T |
getStore(java.lang.String storeName,
QueryableStoreType<T> queryableStoreType)
Get a composite object wrapping the instances of the
StateStore with the provided
storeName and QueryableStoreType |
public QueryableStoreProvider(java.util.List<StateStoreProvider> storeProviders, GlobalStateStoreProvider globalStateStoreProvider)
public <T> T getStore(java.lang.String storeName, QueryableStoreType<T> queryableStoreType)
StateStore
with the provided
storeName and QueryableStoreType
T
- The expected type of the returned storestoreName
- name of the storequeryableStoreType
- accept stores passing QueryableStoreType.accepts(StateStore)