Interface WrappedStateStore
-
- All Superinterfaces:
StateStore
- All Known Implementing Classes:
ChangeLoggingKeyValueBytesStore
,InMemoryKeyValueLoggedStore
,MeteredKeyValueStore
,MeteredSessionStore
,MeteredWindowStore
,RocksDBSessionStore
,RocksDBWindowStore
,WrappedStateStore.AbstractStateStore
public interface WrappedStateStore extends StateStore
A storage engine wrapper for utilities like logging, caching, and metering.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static class
WrappedStateStore.AbstractStateStore
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description StateStore
inner()
Return the inner most storage engineStateStore
wrappedStore()
Return the state store this store directly wraps-
Methods inherited from interface org.apache.kafka.streams.processor.StateStore
close, flush, init, isOpen, name, persistent
-
-
-
-
Method Detail
-
inner
StateStore inner()
Return the inner most storage engine- Returns:
- wrapped inner storage engine
-
wrappedStore
StateStore wrappedStore()
Return the state store this store directly wraps- Returns:
- the state store this store directly wraps
-
-