public class StreamThreadStateStoreProvider extends java.lang.Object implements StateStoreProvider
Constructor and Description |
---|
StreamThreadStateStoreProvider(StreamThread streamThread) |
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 StreamThreadStateStoreProvider(StreamThread streamThread)
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