Class GlobalStateStoreProvider
- java.lang.Object
-
- org.apache.kafka.streams.state.internals.GlobalStateStoreProvider
-
- All Implemented Interfaces:
StateStoreProvider
public class GlobalStateStoreProvider extends Object implements StateStoreProvider
-
-
Constructor Summary
Constructors Constructor Description GlobalStateStoreProvider(Map<String,StateStore> globalStateStores)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <T> List<T>
stores(String storeName, QueryableStoreType<T> queryableStoreType)
Find instances of StateStore that are accepted byQueryableStoreType.accepts(org.apache.kafka.streams.processor.StateStore)
and have the provided storeName.
-
-
-
Constructor Detail
-
GlobalStateStoreProvider
public GlobalStateStoreProvider(Map<String,StateStore> globalStateStores)
-
-
Method Detail
-
stores
public <T> List<T> stores(String storeName, QueryableStoreType<T> queryableStoreType)
Description copied from interface:StateStoreProvider
Find instances of StateStore that are accepted byQueryableStoreType.accepts(org.apache.kafka.streams.processor.StateStore)
and have the provided storeName.- Specified by:
stores
in interfaceStateStoreProvider
- Type Parameters:
T
- The type of the Store- Parameters:
storeName
- name of the storequeryableStoreType
- filter stores based on this queryableStoreType- Returns:
- List of the instances of the store in this topology. Empty List if not found
-
-