CachedStateStore¶
CachedStateStore
is an abstraction of cached state stores.
Contract¶
flushCache¶
void flushCache()
Used when:
ProcessorStateManager
is requested to flush store caches
setFlushListener¶
boolean setFlushListener(
CacheFlushListener<K, V> listener,
boolean sendOldValues)
Implementations¶
CachingKeyValueStore
CachingSessionStore
CachingWindowStore
- WrappedStateStore