Package org.apache.kafka.streams.state
Class QueryableStoreTypes.SessionStoreType<K,V>
java.lang.Object
org.apache.kafka.streams.state.QueryableStoreTypes.SessionStoreType<K,V>
- All Implemented Interfaces:
QueryableStoreType<ReadOnlySessionStore<K,
V>>
- Enclosing class:
- QueryableStoreTypes
-
Method Summary
Modifier and TypeMethodDescriptionboolean
accepts
(StateStore stateStore) Called when searching forStateStore
s to see if they match the type expected by implementors of this interface.Create an instance ofT
(usually a facade) that developers can use to query the underlyingStateStore
s.
-
Method Details
-
create
public ReadOnlySessionStore<K,V> create(org.apache.kafka.streams.state.internals.StateStoreProvider storeProvider, String storeName) Description copied from interface:QueryableStoreType
Create an instance ofT
(usually a facade) that developers can use to query the underlyingStateStore
s.- Parameters:
storeProvider
- provides access to all the underlying StateStore instancesstoreName
- The name of the Store- Returns:
- a read-only interface over a
StateStore
(cf.QueryableStoreTypes.KeyValueStoreType
)
-
accepts
Description copied from interface:QueryableStoreType
Called when searching forStateStore
s to see if they match the type expected by implementors of this interface.- Specified by:
accepts
in interfaceQueryableStoreType<T>
- Parameters:
stateStore
- The stateStore- Returns:
- true if it is a match
-