public class GlobalStateStoreProvider extends java.lang.Object implements StateStoreProvider
Constructor and Description |
---|
GlobalStateStoreProvider(java.util.Map<java.lang.String,StateStore> globalStateStores) |
Modifier and Type | Method and Description |
---|---|
<T> java.util.List<T> |
stores(java.lang.String storeName,
QueryableStoreType<T> queryableStoreType)
Find instances of StateStore that are accepted by
QueryableStoreType.accepts(org.apache.kafka.streams.processor.StateStore) and
have the provided storeName. |
public GlobalStateStoreProvider(java.util.Map<java.lang.String,StateStore> globalStateStores)
public <T> java.util.List<T> stores(java.lang.String storeName, QueryableStoreType<T> queryableStoreType)
StateStoreProvider
QueryableStoreType.accepts(org.apache.kafka.streams.processor.StateStore)
and
have the provided storeName.stores
in interface StateStoreProvider
T
- The type of the StorestoreName
- name of the storequeryableStoreType
- filter stores based on this queryableStoreType