Package org.apache.kafka.streams.state.internals

Interface StateStoreProvider

All Known Implementing Classes:

GlobalStateStoreProvider, WrappingStoreProvider

public interface StateStoreProvider

Provides access to StateStores that have been created as part of the ProcessorTopology. To get access to custom stores developers should implement QueryableStoreType.

See Also:

QueryableStoreTypes

Method Summary

Modifier and Type	Method	Description
<T> List<T>	stores(String storeName, QueryableStoreType<T> queryableStoreType)	Find instances of StateStore that are accepted by QueryableStoreType.accepts(org.apache.kafka.streams.processor.StateStore) and have the provided storeName.

Method Detail

stores

<T> List<T> stores(String storeName,
                   QueryableStoreType<T> queryableStoreType)

Find instances of StateStore that are accepted by QueryableStoreType.accepts(org.apache.kafka.streams.processor.StateStore) and have the provided storeName.

Type Parameters:

T - The type of the Store

Parameters:

storeName - name of the store

queryableStoreType - filter stores based on this queryableStoreType

Returns:

List of the instances of the store in this topology. Empty List if not found