Class Hierarchy
- java.lang.Object
- org.apache.kafka.streams.state.HostInfo
- org.apache.kafka.streams.state.QueryableStoreTypes
- org.apache.kafka.streams.state.QueryableStoreTypes.KeyValueStoreType<K,
V> - org.apache.kafka.streams.state.QueryableStoreTypes.SessionStoreType<K,
V> - org.apache.kafka.streams.state.QueryableStoreTypes.WindowStoreType<K,
V> - org.apache.kafka.streams.state.StateSerdes<K,
V> - org.apache.kafka.streams.state.Stores
- org.apache.kafka.streams.state.StreamsMetadata
- org.apache.kafka.streams.state.ValueAndTimestamp<V>
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.WindowStoreIterator<V> (also extends java.io.Closeable)
- org.apache.kafka.streams.state.WindowStoreIterator<V> (also extends org.apache.kafka.streams.state.KeyValueIterator<K,
V>)
- org.apache.kafka.streams.state.KeyValueIterator<K,
- java.io.Closeable
- java.util.Iterator<E>
- org.apache.kafka.streams.state.KeyValueIterator<K,
V> (also extends java.io.Closeable) - org.apache.kafka.streams.state.WindowStoreIterator<V> (also extends java.io.Closeable)
- org.apache.kafka.streams.state.KeyValueIterator<K,
- org.apache.kafka.streams.state.QueryableStoreType<T>
- org.apache.kafka.streams.state.ReadOnlyKeyValueStore<K,
V> - org.apache.kafka.streams.state.KeyValueStore<K,
V> (also extends org.apache.kafka.streams.processor.StateStore) - org.apache.kafka.streams.state.TimestampedKeyValueStore<K,
V>
- org.apache.kafka.streams.state.TimestampedKeyValueStore<K,
- org.apache.kafka.streams.state.KeyValueStore<K,
- org.apache.kafka.streams.state.ReadOnlySessionStore<K,
AGG> - org.apache.kafka.streams.state.SessionStore<K,
AGG> (also extends org.apache.kafka.streams.processor.StateStore)
- org.apache.kafka.streams.state.SessionStore<K,
- org.apache.kafka.streams.state.ReadOnlyWindowStore<K,
V> - org.apache.kafka.streams.state.WindowStore<K,
V> (also extends org.apache.kafka.streams.processor.StateStore) - org.apache.kafka.streams.state.TimestampedWindowStore<K,
V>
- org.apache.kafka.streams.state.TimestampedWindowStore<K,
- org.apache.kafka.streams.state.WindowStore<K,
- org.apache.kafka.streams.state.RocksDBConfigSetter
- org.apache.kafka.streams.processor.StateStore
- org.apache.kafka.streams.state.KeyValueStore<K,
V> (also extends org.apache.kafka.streams.state.ReadOnlyKeyValueStore<K, V>) - org.apache.kafka.streams.state.TimestampedKeyValueStore<K,
V>
- org.apache.kafka.streams.state.TimestampedKeyValueStore<K,
- org.apache.kafka.streams.state.SessionStore<K,
AGG> (also extends org.apache.kafka.streams.state.ReadOnlySessionStore<K, AGG>) - org.apache.kafka.streams.state.WindowStore<K,
V> (also extends org.apache.kafka.streams.state.ReadOnlyWindowStore<K, V>) - org.apache.kafka.streams.state.TimestampedWindowStore<K,
V>
- org.apache.kafka.streams.state.TimestampedWindowStore<K,
- org.apache.kafka.streams.state.KeyValueStore<K,
- org.apache.kafka.streams.state.StoreBuilder<T>
- org.apache.kafka.streams.state.StoreSupplier<T>
- org.apache.kafka.streams.state.KeyValueBytesStoreSupplier
- org.apache.kafka.streams.state.SessionBytesStoreSupplier
- org.apache.kafka.streams.state.WindowBytesStoreSupplier
- org.apache.kafka.streams.state.TimestampedBytesStore