public static class QueryableStoreTypes.KeyValueStoreType<K,V> extends Object
Modifier and Type | Method and Description |
---|---|
ReadOnlyKeyValueStore<K,V> |
create(org.apache.kafka.streams.state.internals.StateStoreProvider storeProvider,
String storeName)
Create an instance of
T (usually a facade) that developers can use
to query the underlying StateStore s. |
public ReadOnlyKeyValueStore<K,V> create(org.apache.kafka.streams.state.internals.StateStoreProvider storeProvider, String storeName)
QueryableStoreType
T
(usually a facade) that developers can use
to query the underlying StateStore
s.storeProvider
- provides access to all the underlying StateStore instancesstoreName
- The name of the StoreStateStore
(cf. QueryableStoreTypes.KeyValueStoreType
)