Hierarchy For Package org.apache.kafka.streams.state

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • org.apache.kafka.streams.state.BuiltInDslStoreSuppliers
  • org.apache.kafka.streams.state.BuiltInDslStoreSuppliers.InMemoryDslStoreSuppliers (implements org.apache.kafka.streams.state.DslStoreSuppliers)
  • org.apache.kafka.streams.state.BuiltInDslStoreSuppliers.RocksDBDslStoreSuppliers (implements org.apache.kafka.streams.state.DslStoreSuppliers)
  • org.apache.kafka.streams.state.DslKeyValueParams
  • org.apache.kafka.streams.state.DslSessionParams
  • org.apache.kafka.streams.state.DslWindowParams
  • 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>
  • org.apache.kafka.streams.state.VersionedRecord<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.VersionedRecordIterator<V> (also extends java.util.Iterator<E>)
    • org.apache.kafka.streams.state.WindowStoreIterator<V> (also extends org.apache.kafka.streams.state.KeyValueIterator<K,V>)
• org.apache.kafka.common.Configurable
  • org.apache.kafka.streams.state.DslStoreSuppliers
• 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.VersionedRecordIterator<V> (also extends java.io.Closeable)
• 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.VersionedBytesStore (also extends org.apache.kafka.streams.state.TimestampedBytesStore)
• 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.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.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.VersionedBytesStore (also extends org.apache.kafka.streams.state.TimestampedBytesStore)
  • org.apache.kafka.streams.state.SessionStore<K,AGG> (also extends org.apache.kafka.streams.state.ReadOnlySessionStore<K,AGG>)
  • org.apache.kafka.streams.state.VersionedKeyValueStore<K,V>
  • 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.StoreBuilder<T>
• org.apache.kafka.streams.state.StoreSupplier<T>
  • org.apache.kafka.streams.state.KeyValueBytesStoreSupplier
    • org.apache.kafka.streams.state.VersionedBytesStoreSupplier
  • org.apache.kafka.streams.state.SessionBytesStoreSupplier
  • org.apache.kafka.streams.state.WindowBytesStoreSupplier
• org.apache.kafka.streams.state.TimestampedBytesStore
  • org.apache.kafka.streams.state.VersionedBytesStore (also extends org.apache.kafka.streams.state.KeyValueStore<K,V>)