public interface StateStoreProvider
StateStore
s that have been created
as part of the ProcessorTopology
.
To get access to custom stores developers should implement QueryableStoreType
.QueryableStoreTypes
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. |
<T> java.util.List<T> stores(java.lang.String storeName, QueryableStoreType<T> queryableStoreType)
QueryableStoreType.accepts(org.apache.kafka.streams.processor.StateStore)
and
have the provided storeName.T
- The type of the StorestoreName
- name of the storequeryableStoreType
- filter stores based on this queryableStoreType