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

public static class QueryableStoreTypes.SessionStoreType<K,V> extends Object
  • 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