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

Class StreamThreadStateStoreProvider

java.lang.Object

org.apache.kafka.streams.state.internals.StreamThreadStateStoreProvider

public class StreamThreadStateStoreProvider
extends Object

Constructor Summary

Constructors

Constructor	Description
StreamThreadStateStoreProvider(StreamThread streamThread)

Method Summary

Modifier and Type	Method	Description
<T> List<T>	stores(StoreQueryParameters storeQueryParams)

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamThreadStateStoreProvider

public StreamThreadStateStoreProvider(StreamThread streamThread)

Method Detail

stores

public <T> List<T> stores(StoreQueryParameters storeQueryParams)