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

Class QueryableStoreProvider

java.lang.Object

org.apache.kafka.streams.state.internals.QueryableStoreProvider

public class QueryableStoreProvider
extends Object

A wrapper over all of the StateStoreProviders in a Topology

Constructor Summary

Constructors

Constructor	Description
QueryableStoreProvider(List<StreamThreadStateStoreProvider> storeProviders, GlobalStateStoreProvider globalStateStoreProvider)

Method Summary

Modifier and Type	Method	Description
<T> T	getStore(StoreQueryParameters<T> storeQueryParameters)	Get a composite object wrapping the instances of the StateStore with the provided storeName and QueryableStoreType

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

QueryableStoreProvider

public QueryableStoreProvider(List<StreamThreadStateStoreProvider> storeProviders,
                              GlobalStateStoreProvider globalStateStoreProvider)

Method Detail

getStore

public <T> T getStore(StoreQueryParameters<T> storeQueryParameters)

Get a composite object wrapping the instances of the StateStore with the provided storeName and QueryableStoreType

Type Parameters:

T - The expected type of the returned store

Parameters:

storeQueryParameters - if stateStoresEnabled is used i.e. staleStoresEnabled is true, include standbys and recovering stores; if stateStoresDisabled i.e. staleStoresEnabled is false, only include running actives; if partition is null then it fetches all local partitions on the instance; if partition is set then it fetches a specific partition.

Returns:

A composite object that wraps the store instances.