Class QueryableStoreProvider


  • public class QueryableStoreProvider
    extends java.lang.Object
    A wrapper over all of the StateStoreProviders in a Topology
    • Method Detail

      • getStore

        public <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
        Type Parameters:
        T - The expected type of the returned store
        Parameters:
        storeName - name of the store
        queryableStoreType - accept stores passing QueryableStoreType.accepts(StateStore)
        Returns:
        A composite object that wraps the store instances.