Package org.apache.kafka.streams.state
Interface QueryableStoreType<T>
-
- Type Parameters:
T- The store type
- All Known Implementing Classes:
QueryableStoreTypes.KeyValueStoreType,QueryableStoreTypes.SessionStoreType,QueryableStoreTypes.WindowStoreType
public interface QueryableStoreType<T>Used to enable querying of customStateStoretypes via theKafkaStreamsAPI.- See Also:
QueryableStoreTypes
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description booleanaccepts(StateStore stateStore)Called when searching forStateStores to see if they match the type expected by implementors of this interface.Tcreate(org.apache.kafka.streams.state.internals.StateStoreProvider storeProvider, String storeName)Create an instance ofT(usually a facade) that developers can use to query the underlyingStateStores.
-
-
-
Method Detail
-
accepts
boolean accepts(StateStore stateStore)
Called when searching forStateStores to see if they match the type expected by implementors of this interface.- Parameters:
stateStore- The stateStore- Returns:
- true if it is a match
-
create
T create(org.apache.kafka.streams.state.internals.StateStoreProvider storeProvider, String storeName)
Create an instance ofT(usually a facade) that developers can use to query the underlyingStateStores.- 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)
-
-