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

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • org.rocksdb.AbstractNativeReference (implements java.lang.AutoCloseable)
    • org.rocksdb.AbstractImmutableNativeReference
      • org.rocksdb.RocksObject
        • org.rocksdb.Options (implements org.rocksdb.ColumnFamilyOptionsInterface<T>, org.rocksdb.DBOptionsInterface<T>, org.rocksdb.MutableColumnFamilyOptionsInterface<T>)
          • org.apache.kafka.streams.state.internals.RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter
  • org.apache.kafka.streams.state.internals.AbstractRocksDBSegmentedBytesStore<S> (implements org.apache.kafka.streams.state.internals.SegmentedBytesStore)
    • org.apache.kafka.streams.state.internals.RocksDBSegmentedBytesStore
    • org.apache.kafka.streams.state.internals.RocksDBTimestampedSegmentedBytesStore
  • 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.TimestampedKeyValueStoreBuilder<K,V>
    • org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder<K,V>
    • org.apache.kafka.streams.state.internals.WindowStoreBuilder<K,V>
  • org.apache.kafka.streams.state.internals.BufferKey (implements java.lang.Comparable<T>)
  • org.apache.kafka.streams.state.internals.BufferValue
  • 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.DelegatingPeekingKeyValueIterator<K,V> (implements org.apache.kafka.streams.state.KeyValueIterator<K,V>, org.apache.kafka.streams.state.internals.PeekingKeyValueIterator<K,V>)
  • org.apache.kafka.streams.state.internals.GlobalStateStoreProvider (implements org.apache.kafka.streams.state.internals.StateStoreProvider)
  • org.apache.kafka.streams.state.internals.InMemoryKeyValueStore (implements org.apache.kafka.streams.state.KeyValueStore<K,V>)
  • org.apache.kafka.streams.state.internals.InMemorySessionBytesStoreSupplier (implements org.apache.kafka.streams.state.SessionBytesStoreSupplier)
  • org.apache.kafka.streams.state.internals.InMemorySessionStore (implements org.apache.kafka.streams.state.SessionStore<K,AGG>)
  • org.apache.kafka.streams.state.internals.InMemoryTimeOrderedKeyValueBuffer<K,V> (implements org.apache.kafka.streams.state.internals.TimeOrderedKeyValueBuffer<K,V>)
  • org.apache.kafka.streams.state.internals.InMemoryTimeOrderedKeyValueBuffer.Builder<K,V> (implements org.apache.kafka.streams.state.StoreBuilder<T>)
  • org.apache.kafka.streams.state.internals.InMemoryWindowBytesStoreSupplier (implements org.apache.kafka.streams.state.WindowBytesStoreSupplier)
  • org.apache.kafka.streams.state.internals.InMemoryWindowStore (implements org.apache.kafka.streams.state.WindowStore<K,V>)
  • org.apache.kafka.streams.state.internals.KeyValueIteratorFacade<K,V> (implements org.apache.kafka.streams.state.KeyValueIterator<K,V>)
  • org.apache.kafka.streams.state.internals.KeyValueToTimestampedKeyValueByteStoreAdapter (implements org.apache.kafka.streams.state.KeyValueStore<K,V>)
  • org.apache.kafka.streams.state.internals.Maybe<T>
  • org.apache.kafka.streams.state.internals.MemoryLRUCache (implements org.apache.kafka.streams.state.KeyValueStore<K,V>)
    • org.apache.kafka.streams.state.internals.MemoryNavigableLRUCache
  • org.apache.kafka.streams.state.internals.MeteredTimestampedKeyValueStore.RawAndDeserializedValue<ValueType>
  • org.apache.kafka.streams.state.internals.Murmur3
  • org.apache.kafka.streams.state.internals.Murmur3.IncrementalHash32
  • org.apache.kafka.streams.state.internals.OffsetCheckpoint
  • org.apache.kafka.streams.state.internals.QueryableStoreProvider
  • org.apache.kafka.streams.state.internals.ReadOnlyKeyValueStoreFacade<K,V> (implements org.apache.kafka.streams.state.ReadOnlyKeyValueStore<K,V>)
  • org.apache.kafka.streams.state.internals.ReadOnlyWindowStoreFacade<K,V> (implements org.apache.kafka.streams.state.ReadOnlyWindowStore<K,V>)
  • org.apache.kafka.streams.state.internals.RecordConverters
  • 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.internals.BatchWritingStore, org.apache.kafka.streams.state.KeyValueStore<K,V>)
    • org.apache.kafka.streams.state.internals.RocksDBTimestampedStore (implements org.apache.kafka.streams.state.TimestampedBytesStore)
  • 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
  • org.apache.kafka.streams.state.internals.ThreadCache
  • org.apache.kafka.streams.state.internals.TimeOrderedKeyValueBuffer.Eviction<K,V>
  • org.apache.kafka.streams.state.internals.ValueAndTimestampSerializer<V> (implements org.apache.kafka.streams.kstream.internals.WrappingNullableSerializer<Outer,InnerK,InnerV>)
  • org.apache.kafka.streams.state.internals.WindowKeySchema (implements org.apache.kafka.streams.state.internals.SegmentedBytesStore.KeySchema)
  • org.apache.kafka.streams.state.internals.WrappedStateStore<S,K,V> (implements org.apache.kafka.streams.state.internals.CachedStateStore<K,V>, org.apache.kafka.streams.processor.StateStore)
    • org.apache.kafka.streams.state.internals.CachingKeyValueStore (implements org.apache.kafka.streams.state.internals.CachedStateStore<K,V>, org.apache.kafka.streams.state.KeyValueStore<K,V>)
    • org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStore (implements org.apache.kafka.streams.state.KeyValueStore<K,V>)
      • org.apache.kafka.streams.state.internals.ChangeLoggingTimestampedKeyValueBytesStore
    • org.apache.kafka.streams.state.internals.MeteredKeyValueStore<K,V> (implements org.apache.kafka.streams.state.KeyValueStore<K,V>)
      • org.apache.kafka.streams.state.internals.MeteredTimestampedKeyValueStore<K,V> (implements org.apache.kafka.streams.state.TimestampedKeyValueStore<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 (implements org.apache.kafka.streams.state.SessionStore<K,AGG>)
    • org.apache.kafka.streams.state.internals.RocksDBWindowStore (implements org.apache.kafka.streams.state.WindowStore<K,V>)
  • org.apache.kafka.streams.kstream.internals.WrappingNullableSerde<T,InnerK,InnerV> (implements org.apache.kafka.common.serialization.Serde<T>)
    • org.apache.kafka.streams.state.internals.ValueAndTimestampSerde<V>
  • org.apache.kafka.streams.state.internals.WrappingStoreProvider (implements org.apache.kafka.streams.state.internals.StateStoreProvider)

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.internals.BatchWritingStore
  • org.apache.kafka.streams.state.internals.Segment (also extends org.apache.kafka.streams.state.KeyValueStore<K,V>)
• org.apache.kafka.streams.state.internals.CachedStateStore<K,V>
• org.apache.kafka.streams.state.internals.CacheFlushListener<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.internals.MemoryLRUCache.EldestEntryRemovalListener
• 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.internals.Segment (also extends org.apache.kafka.streams.state.internals.BatchWritingStore)
• org.apache.kafka.streams.state.internals.RecordConverter
• org.apache.kafka.streams.state.internals.SegmentedBytesStore.KeySchema
• 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.internals.Segment (also extends org.apache.kafka.streams.state.internals.BatchWritingStore)
  • org.apache.kafka.streams.state.internals.SegmentedBytesStore
  • org.apache.kafka.streams.state.internals.TimeOrderedKeyValueBuffer<K,V>
• org.apache.kafka.streams.state.internals.StateStoreProvider
• org.apache.kafka.streams.state.internals.ThreadCache.DirtyEntryFlushListener