QueryableStoreTypes.SessionStoreType (streams 8.1.1-ce API)

java.lang.Object

org.apache.kafka.streams.state.QueryableStoreTypes.SessionStoreType<K,V>

All Implemented Interfaces:: QueryableStoreType<ReadOnlySessionStore<K,V>>

Enclosing class:: QueryableStoreTypes

public static class QueryableStoreTypes.SessionStoreType<K,V>extends Object

Method Summary
Modifier and Type
Method
Description
boolean
accepts(StateStore stateStore)
Called when searching for StateStores to see if they match the type expected by implementors of this interface.
ReadOnlySessionStore<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 StateStores.
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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 of T (usually a facade) that developers can use to query the underlying StateStores.
  Parameters:
  storeProvider - provides access to all the underlying StateStore instances
  storeName - The name of the Store
  Returns:
  a read-only interface over a StateStore (cf. QueryableStoreTypes.KeyValueStoreType)
- accepts
  public boolean accepts(StateStore stateStore)
  Description copied from interface: QueryableStoreType
  Called when searching for StateStores to see if they match the type expected by implementors of this interface.
  Specified by:
  accepts in interface QueryableStoreType<T>
  Parameters:
  stateStore - The stateStore
  Returns:
  true if it is a match