Class WrappingStoreProvider
- java.lang.Object
-
- org.apache.kafka.streams.state.internals.WrappingStoreProvider
-
- All Implemented Interfaces:
StateStoreProvider
public class WrappingStoreProvider extends java.lang.Object implements StateStoreProvider
Provides a wrapper over multiple underlyingStateStoreProvider
s
-
-
Constructor Summary
Constructors Constructor Description WrappingStoreProvider(java.util.List<StateStoreProvider> storeProviders)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <T> java.util.List<T>
stores(java.lang.String storeName, QueryableStoreType<T> type)
Provides access toStateStore
s accepted byQueryableStoreType.accepts(StateStore)
-
-
-
Constructor Detail
-
WrappingStoreProvider
public WrappingStoreProvider(java.util.List<StateStoreProvider> storeProviders)
-
-
Method Detail
-
stores
public <T> java.util.List<T> stores(java.lang.String storeName, QueryableStoreType<T> type)
Provides access toStateStore
s accepted byQueryableStoreType.accepts(StateStore)
- Specified by:
stores
in interfaceStateStoreProvider
- Type Parameters:
T
- The type of the Store, for example,ReadOnlyKeyValueStore
- Parameters:
storeName
- name of the storetype
- TheQueryableStoreType
- Returns:
- a List of all the stores with the storeName and are accepted by
QueryableStoreType.accepts(StateStore)
-
-