Uses of Class
io.streamthoughts.azkarra.api.query.LocalStoreAccessor
-
Packages that use LocalStoreAccessor Package Description io.streamthoughts.azkarra.api.streams -
-
Uses of LocalStoreAccessor in io.streamthoughts.azkarra.api.streams
Methods in io.streamthoughts.azkarra.api.streams that return LocalStoreAccessor Modifier and Type Method Description <K,V>
LocalStoreAccessor<org.apache.kafka.streams.state.ReadOnlyKeyValueStore<K,V>>KafkaStreamsContainer. getLocalKeyValueStore(String storeName)
<K,V>
LocalStoreAccessor<org.apache.kafka.streams.state.ReadOnlySessionStore<K,V>>KafkaStreamsContainer. getLocalSessionStore(String storeName)
<T> LocalStoreAccessor<T>
KafkaStreamsContainer. getLocalStoreAccess(String storeName, org.apache.kafka.streams.state.QueryableStoreType<T> storeType)
<K,V>
LocalStoreAccessor<org.apache.kafka.streams.state.ReadOnlyWindowStore<K,V>>KafkaStreamsContainer. getLocalWindowStore(String storeName)
-