Uses of Class
io.streamthoughts.azkarra.api.query.LocalStoreAccessor
-
Packages that use LocalStoreAccessor Package Description io.streamthoughts.azkarra.api.query io.streamthoughts.azkarra.runtime.streams -
-
Uses of LocalStoreAccessor in io.streamthoughts.azkarra.api.query
Methods in io.streamthoughts.azkarra.api.query that return LocalStoreAccessor Modifier and Type Method Description <K,V>
LocalStoreAccessor<org.apache.kafka.streams.state.ReadOnlyKeyValueStore<K,V>>LocalStoreAccessProvider. localKeyValueStore(String store)
Gets a read-only access to a local key-value store.<K,V>
LocalStoreAccessor<org.apache.kafka.streams.state.ReadOnlySessionStore<K,V>>LocalStoreAccessProvider. localSessionStore(String store)
Gets a read-only access to a local session store.<K,V>
LocalStoreAccessor<org.apache.kafka.streams.state.ReadOnlyKeyValueStore<K,org.apache.kafka.streams.state.ValueAndTimestamp<V>>>LocalStoreAccessProvider. localTimestampedKeyValueStore(String store)
Gets a read-only access to the local timestamped key-value store.<K,V>
LocalStoreAccessor<org.apache.kafka.streams.state.ReadOnlyWindowStore<K,org.apache.kafka.streams.state.ValueAndTimestamp<V>>>LocalStoreAccessProvider. localTimestampedWindowStore(String store)
Gets a read-only access to a local window store.<K,V>
LocalStoreAccessor<org.apache.kafka.streams.state.ReadOnlyWindowStore<K,V>>LocalStoreAccessProvider. localWindowStore(String store)
Gets a read-only access to a local window store. -
Uses of LocalStoreAccessor in io.streamthoughts.azkarra.runtime.streams
Methods in io.streamthoughts.azkarra.runtime.streams that return LocalStoreAccessor Modifier and Type Method Description <K,V>
LocalStoreAccessor<org.apache.kafka.streams.state.ReadOnlyKeyValueStore<K,V>>LocalKafkaStreamsContainer. localKeyValueStore(String store)
Gets a read-only access to a local key-value store.<K,V>
LocalStoreAccessor<org.apache.kafka.streams.state.ReadOnlySessionStore<K,V>>LocalKafkaStreamsContainer. localSessionStore(String storeName)
Gets a read-only access to a local session store.<K,V>
LocalStoreAccessor<org.apache.kafka.streams.state.ReadOnlyKeyValueStore<K,org.apache.kafka.streams.state.ValueAndTimestamp<V>>>LocalKafkaStreamsContainer. localTimestampedKeyValueStore(String storeName)
Gets a read-only access to the local timestamped key-value store.<K,V>
LocalStoreAccessor<org.apache.kafka.streams.state.ReadOnlyWindowStore<K,org.apache.kafka.streams.state.ValueAndTimestamp<V>>>LocalKafkaStreamsContainer. localTimestampedWindowStore(String storeName)
Gets a read-only access to a local window store.<K,V>
LocalStoreAccessor<org.apache.kafka.streams.state.ReadOnlyWindowStore<K,V>>LocalKafkaStreamsContainer. localWindowStore(String storeName)
Gets a read-only access to a local window store.
-