AbstractStoreBuilder<K,V,T extends StateStore> |
|
ChangeLoggingKeyValueBytesStore |
|
CompositeReadOnlyKeyValueStore<K,V> |
|
CompositeReadOnlySessionStore<K,V> |
|
CompositeReadOnlyWindowStore<K,V> |
|
ContextualRecord |
|
GlobalStateStoreProvider |
|
InMemoryKeyValueLoggedStore<K,V> |
|
InMemoryKeyValueStore<K,V> |
|
InMemoryTimeOrderedKeyValueBuffer |
|
InMemoryTimeOrderedKeyValueBuffer.Builder |
|
KeyValueStoreBuilder<K,V> |
|
MemoryLRUCache<K,V> |
An in-memory LRU cache store based on HashSet and HashMap.
|
MemoryNavigableLRUCache<K,V> |
|
MeteredKeyValueStore<K,V> |
A Metered KeyValueStore wrapper that is used for recording operation metrics, and hence its
inner KeyValueStore implementation do not need to provide its own metrics collecting functionality.
|
MeteredSessionStore<K,V> |
|
MeteredWindowStore<K,V> |
|
OffsetCheckpoint |
This class saves out a map of topic/partition=>offsets to a file.
|
QueryableStoreProvider |
|
RocksDbKeyValueBytesStoreSupplier |
|
RocksDbSessionBytesStoreSupplier |
|
RocksDBSessionStore<K,AGG> |
|
RocksDBStore |
A persistent key-value store based on RocksDB.
|
RocksDbWindowBytesStoreSupplier |
|
RocksDBWindowStore<K,V> |
|
SessionKeySchema |
|
SessionStoreBuilder<K,V> |
|
StreamThreadStateStoreProvider |
Wrapper over StreamThread that implements StateStoreProvider
|
ThreadCache |
An in-memory LRU cache store similar to MemoryLRUCache but byte-based, not
record based
|
WindowKeySchema |
|
WindowStoreBuilder<K,V> |
|
WrappedStateStore.AbstractStateStore |
|
WrappingStoreProvider |
|