Class Hierarchy
- java.lang.Object
- org.apache.kafka.streams.state.internals.AbstractStoreBuilder<K,V,T> (implements org.apache.kafka.streams.state.StoreBuilder<T>)
- org.apache.kafka.streams.state.internals.KeyValueStoreBuilder<K,V>
- org.apache.kafka.streams.state.internals.SessionStoreBuilder<K,V>
- org.apache.kafka.streams.state.internals.WindowStoreBuilder<K,V>
- org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStore<K,V> (implements org.apache.kafka.streams.state.ReadOnlyKeyValueStore<K,V>)
- org.apache.kafka.streams.state.internals.CompositeReadOnlySessionStore<K,V> (implements org.apache.kafka.streams.state.ReadOnlySessionStore<K,AGG>)
- org.apache.kafka.streams.state.internals.CompositeReadOnlyWindowStore<K,V> (implements org.apache.kafka.streams.state.ReadOnlyWindowStore<K,V>)
- org.apache.kafka.streams.state.internals.ContextualRecord
- org.apache.kafka.streams.state.internals.GlobalStateStoreProvider (implements org.apache.kafka.streams.state.internals.StateStoreProvider)
- org.apache.kafka.streams.state.internals.InMemoryKeyValueStore<K,V> (implements org.apache.kafka.streams.state.KeyValueStore<K,V>)
- org.apache.kafka.streams.state.internals.InMemoryTimeOrderedKeyValueBuffer (implements org.apache.kafka.streams.state.internals.TimeOrderedKeyValueBuffer)
- org.apache.kafka.streams.state.internals.InMemoryTimeOrderedKeyValueBuffer.Builder (implements org.apache.kafka.streams.state.StoreBuilder<T>)
- org.apache.kafka.streams.state.internals.MemoryLRUCache<K,V> (implements org.apache.kafka.streams.state.KeyValueStore<K,V>)
- org.apache.kafka.streams.state.internals.MemoryNavigableLRUCache<K,V>
- org.apache.kafka.streams.state.internals.OffsetCheckpoint
- org.apache.kafka.streams.state.internals.QueryableStoreProvider
- org.apache.kafka.streams.state.internals.RocksDbKeyValueBytesStoreSupplier (implements org.apache.kafka.streams.state.KeyValueBytesStoreSupplier)
- org.apache.kafka.streams.state.internals.RocksDbSessionBytesStoreSupplier (implements org.apache.kafka.streams.state.SessionBytesStoreSupplier)
- org.apache.kafka.streams.state.internals.RocksDBStore (implements org.apache.kafka.streams.state.KeyValueStore<K,V>)
- org.apache.kafka.streams.state.internals.RocksDbWindowBytesStoreSupplier (implements org.apache.kafka.streams.state.WindowBytesStoreSupplier)
- org.apache.kafka.streams.state.internals.SessionKeySchema (implements org.apache.kafka.streams.state.internals.SegmentedBytesStore.KeySchema)
- org.apache.kafka.streams.state.internals.StreamThreadStateStoreProvider (implements org.apache.kafka.streams.state.internals.StateStoreProvider)
- org.apache.kafka.streams.state.internals.ThreadCache
- org.apache.kafka.streams.state.internals.WindowKeySchema (implements org.apache.kafka.streams.state.internals.SegmentedBytesStore.KeySchema)
- org.apache.kafka.streams.state.internals.WrappedStateStore.AbstractStateStore (implements org.apache.kafka.streams.state.internals.WrappedStateStore)
- org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStore (implements org.apache.kafka.streams.state.KeyValueStore<K,V>)
- org.apache.kafka.streams.state.internals.InMemoryKeyValueLoggedStore<K,V> (implements org.apache.kafka.streams.state.KeyValueStore<K,V>)
- org.apache.kafka.streams.state.internals.MeteredKeyValueStore<K,V> (implements org.apache.kafka.streams.state.KeyValueStore<K,V>)
- org.apache.kafka.streams.state.internals.MeteredSessionStore<K,V> (implements org.apache.kafka.streams.state.SessionStore<K,AGG>)
- org.apache.kafka.streams.state.internals.MeteredWindowStore<K,V> (implements org.apache.kafka.streams.state.WindowStore<K,V>)
- org.apache.kafka.streams.state.internals.RocksDBSessionStore<K,AGG> (implements org.apache.kafka.streams.state.SessionStore<K,AGG>)
- org.apache.kafka.streams.state.internals.RocksDBWindowStore<K,V> (implements org.apache.kafka.streams.state.WindowStore<K,V>)
- org.apache.kafka.streams.state.internals.WrappingStoreProvider (implements org.apache.kafka.streams.state.internals.StateStoreProvider)
- org.apache.kafka.streams.state.internals.AbstractStoreBuilder<K,V,T> (implements org.apache.kafka.streams.state.StoreBuilder<T>)
Interface Hierarchy
- java.lang.AutoCloseable
- java.io.Closeable
- org.apache.kafka.streams.state.KeyValueIterator<K,V> (also extends java.util.Iterator<E>)
- org.apache.kafka.streams.state.internals.PeekingKeyValueIterator<K,V>
- org.apache.kafka.streams.state.KeyValueIterator<K,V> (also extends java.util.Iterator<E>)
- java.io.Closeable
- org.apache.kafka.streams.state.internals.CachedStateStore<K,V>
- java.util.Iterator<E>
- org.apache.kafka.streams.state.KeyValueIterator<K,V> (also extends java.io.Closeable)
- org.apache.kafka.streams.state.internals.PeekingKeyValueIterator<K,V>
- org.apache.kafka.streams.state.KeyValueIterator<K,V> (also extends java.io.Closeable)
- org.apache.kafka.streams.state.internals.MemoryLRUCache.EldestEntryRemovalListener<K,V>
- org.apache.kafka.streams.state.internals.SegmentedBytesStore.KeySchema
- org.apache.kafka.streams.processor.StateStore
- org.apache.kafka.streams.state.internals.SegmentedBytesStore
- org.apache.kafka.streams.state.internals.TimeOrderedKeyValueBuffer
- org.apache.kafka.streams.state.internals.WrappedStateStore
- org.apache.kafka.streams.state.internals.StateStoreProvider
- org.apache.kafka.streams.state.internals.ThreadCache.DirtyEntryFlushListener