Hierarchy For All Packages

Package Hierarchies:

• org.apache.flink.state.forst,
• org.apache.flink.state.forst.datatransfer,
• org.apache.flink.state.forst.fs,
• org.apache.flink.state.forst.fs.cache,
• org.apache.flink.state.forst.fs.filemapping,
• org.apache.flink.state.forst.restore,
• org.apache.flink.state.forst.snapshot,
• org.apache.flink.state.forst.sync

Class Hierarchy

• java.lang.Object
  • org.apache.flink.state.forst.sync.AbstractForStStateKeysIterator<K> (implements java.lang.AutoCloseable)
    • org.apache.flink.state.forst.sync.ForStStateKeysAndNamespaceIterator<K,N> (implements java.util.Iterator<E>)
    • org.apache.flink.state.forst.sync.ForStStateKeysIterator<K> (implements java.util.Iterator<E>)
  • org.apache.flink.state.forst.sync.AbstractForStSyncState<K,N,V> (implements org.apache.flink.runtime.state.internal.InternalKvState<K,N,V>, org.apache.flink.api.common.state.State)
  • org.apache.flink.runtime.state.heap.AbstractHeapPriorityQueueElement (implements org.apache.flink.runtime.state.heap.HeapPriorityQueueElement)
    • org.apache.flink.state.forst.sync.ForStDBCachingPriorityQueueSet<E> (implements org.apache.flink.runtime.state.InternalPriorityQueue<T>)
  • org.apache.flink.runtime.state.v2.AbstractKeyedState<K,N,V> (implements org.apache.flink.runtime.state.v2.internal.InternalKeyedState<K,N,V>)
    • org.apache.flink.runtime.state.v2.AbstractAggregatingState<K,N,IN,ACC,OUT> (implements org.apache.flink.runtime.state.v2.internal.InternalAggregatingState<K,N,IN,ACC,OUT>)
      • org.apache.flink.state.forst.ForStAggregatingState<K,N,IN,ACC,OUT> (implements org.apache.flink.state.forst.ForStInnerTable<K,N,V>)
    • org.apache.flink.runtime.state.v2.AbstractListState<K,N,V> (implements org.apache.flink.runtime.state.v2.internal.InternalListState<K,N,V>)
      • org.apache.flink.state.forst.ForStListState<K,N,V> (implements org.apache.flink.state.forst.ForStInnerTable<K,N,V>, org.apache.flink.api.common.state.v2.ListState<T>)
    • org.apache.flink.runtime.state.v2.AbstractMapState<K,N,UK,V> (implements org.apache.flink.runtime.state.v2.internal.InternalMapState<K,N,UK,UV>)
      • org.apache.flink.state.forst.ForStMapState<K,N,UK,UV> (implements org.apache.flink.state.forst.ForStInnerTable<K,N,V>, org.apache.flink.api.common.state.v2.MapState<UK,UV>)
    • org.apache.flink.runtime.state.v2.AbstractReducingState<K,N,V> (implements org.apache.flink.runtime.state.v2.internal.InternalReducingState<K,N,T>)
      • org.apache.flink.state.forst.ForStReducingState<K,N,V> (implements org.apache.flink.state.forst.ForStInnerTable<K,N,V>)
    • org.apache.flink.runtime.state.v2.AbstractValueState<K,N,V> (implements org.apache.flink.runtime.state.v2.internal.InternalValueState<K,N,V>)
      • org.apache.flink.state.forst.ForStValueState<K,N,V> (implements org.apache.flink.state.forst.ForStInnerTable<K,N,V>, org.apache.flink.api.common.state.v2.ValueState<T>)
  • org.apache.flink.runtime.state.AbstractKeyedStateBackend<K> (implements org.apache.flink.runtime.state.CheckpointableKeyedStateBackend<K>, org.apache.flink.api.common.state.InternalCheckpointListener, org.apache.flink.runtime.state.InternalKeyContext<K>, org.apache.flink.runtime.state.TestableKeyedStateBackend<K>)
    • org.apache.flink.state.forst.sync.ForStSyncKeyedStateBackend<K>
  • org.apache.flink.runtime.state.AbstractKeyedStateBackendBuilder<K> (implements org.apache.flink.runtime.state.StateBackendBuilder<T,E>)
    • org.apache.flink.state.forst.sync.ForStSyncKeyedStateBackendBuilder<K>
  • org.apache.flink.runtime.state.AbstractStateBackend (implements org.apache.flink.runtime.state.StateBackend)
    • org.apache.flink.runtime.state.AbstractManagedMemoryStateBackend
      • org.apache.flink.state.forst.ForStStateBackend (implements org.apache.flink.runtime.state.ConfigurableStateBackend)
  • org.apache.flink.runtime.asyncprocessing.AbstractStateIterator<T> (implements org.apache.flink.core.state.InternalStateIterator<T>)
    • org.apache.flink.state.forst.ForStListIterator<V>
    • org.apache.flink.state.forst.ForStMapIterator<T>
  • org.apache.flink.state.forst.fs.cache.BundledCacheLimitPolicy (implements org.apache.flink.state.forst.fs.cache.CacheLimitPolicy)
  • org.apache.flink.state.forst.ContextKey<K,N>
  • org.apache.flink.state.forst.datatransfer.DataTransferStrategy
    • org.apache.flink.state.forst.datatransfer.CopyDataTransferStrategy
      • org.apache.flink.state.forst.datatransfer.ReusableDataTransferStrategy
  • org.apache.flink.state.forst.datatransfer.DataTransferStrategyBuilder
  • org.apache.flink.state.forst.fs.cache.DoubleListLru<K,V> (implements java.lang.Iterable<T>)
    • org.apache.flink.state.forst.fs.cache.FileBasedCache (implements java.io.Closeable)
  • org.apache.flink.state.forst.fs.filemapping.FileMappingManager
  • org.apache.flink.state.forst.fs.filemapping.FileOwnershipDecider
  • org.apache.flink.core.fs.FileSystem (implements org.apache.flink.core.fs.IFileSystem)
    • org.apache.flink.state.forst.fs.ForStFlinkFileSystem (implements java.io.Closeable)
  • org.apache.flink.state.forst.ForStConfigurableOptions (implements java.io.Serializable)
  • org.apache.flink.state.forst.ForStDBGetRequest<K,N,V,R>
    • org.apache.flink.state.forst.ForStDBListGetRequest<K,N,V>
    • org.apache.flink.state.forst.ForStDBMapCheckRequest<K,N,V>
    • org.apache.flink.state.forst.ForStDBRawGetRequest<K,N,V>
    • org.apache.flink.state.forst.ForStDBSingleGetRequest<K,N,V>
  • org.apache.flink.state.forst.ForStDBIterRequest<K,N,UK,UV,R> (implements java.io.Closeable)
    • org.apache.flink.state.forst.ForStDBMapEntryIterRequest<K,N,UK,UV>
    • org.apache.flink.state.forst.ForStDBMapKeyIterRequest<K,N,UK,UV>
    • org.apache.flink.state.forst.ForStDBMapValueIterRequest<K,N,UK,UV>
  • org.apache.flink.state.forst.sync.ForStDBPriorityQueueSetFactory (implements org.apache.flink.runtime.state.PriorityQueueSetFactory)
  • org.apache.flink.state.forst.ForStDBPutRequest<K,N,V>
    • org.apache.flink.state.forst.ForStDBBunchPutRequest<K,N,UK,UV>
    • org.apache.flink.state.forst.ForStDBMultiRawMergePutRequest<K,N,V>
  • org.apache.flink.state.forst.ForStDBTtlCompactFiltersManager
  • org.apache.flink.state.forst.ForStDBWriteBatchWrapper (implements java.lang.AutoCloseable)
  • org.apache.flink.state.forst.fs.ForStFileStatus
  • org.apache.flink.state.forst.fs.ForStFlinkFileSystem.FileStatusWrapper (implements org.apache.flink.core.fs.FileStatus)
  • org.apache.flink.state.forst.ForStGeneralMultiGetOperation (implements org.apache.flink.state.forst.ForStDBOperation)
  • org.apache.flink.state.forst.restore.ForStHeapTimersFullRestoreOperation<K> (implements org.apache.flink.state.forst.restore.ForStRestoreOperation)
  • org.apache.flink.state.forst.ForStIncrementalCheckpointUtils
  • org.apache.flink.state.forst.ForStIncrementalCheckpointUtils.RangeCheckResult
  • org.apache.flink.state.forst.restore.ForStIncrementalRestoreOperation<K> (implements org.apache.flink.state.forst.restore.ForStRestoreOperation)
  • org.apache.flink.state.forst.restore.ForStIncrementalRestoreOperation.RestoredDBInstance (implements java.lang.AutoCloseable)
  • org.apache.flink.state.forst.ForStIterateOperation (implements org.apache.flink.state.forst.ForStDBOperation)
  • org.apache.flink.state.forst.sync.ForStIteratorWrapper (implements java.io.Closeable, org.forstdb.RocksIteratorInterface)
  • org.apache.flink.state.forst.ForStKeyedStateBackend<K> (implements org.apache.flink.runtime.state.AsyncKeyedStateBackend<K>)
  • org.apache.flink.state.forst.ForStKeyedStateBackendBuilder<K> (implements org.apache.flink.runtime.state.StateBackendBuilder<T,E>)
  • org.apache.flink.state.forst.ForStMemoryConfiguration (implements java.io.Serializable)
  • org.apache.flink.state.forst.ForStMemoryControllerUtils
  • org.apache.flink.state.forst.ForStNativeMetricMonitor (implements java.io.Closeable)
  • org.apache.flink.state.forst.ForStNativeMetricOptions (implements java.io.Serializable)
  • org.apache.flink.state.forst.restore.ForStNoneRestoreOperation (implements org.apache.flink.state.forst.restore.ForStRestoreOperation)
  • org.apache.flink.state.forst.ForStOperationUtils
  • org.apache.flink.state.forst.ForStOperationUtils.ForStKvStateInfo (implements java.lang.AutoCloseable)
  • org.apache.flink.state.forst.ForStOptions
  • org.apache.flink.state.forst.ForStPathContainer
  • org.apache.flink.state.forst.sync.ForStPriorityQueueConfig (implements java.io.Serializable)
  • org.apache.flink.state.forst.ForStResourceContainer (implements java.lang.AutoCloseable)
  • org.apache.flink.state.forst.restore.ForStRestoreResult
  • org.apache.flink.state.forst.ForStSerializerUtils
  • org.apache.flink.state.forst.snapshot.ForStSnapshotStrategyBase<K,R> (implements java.lang.AutoCloseable, org.apache.flink.api.common.state.CheckpointListener, org.apache.flink.runtime.state.SnapshotStrategy<S,SR>)
    • org.apache.flink.state.forst.snapshot.ForStNativeFullSnapshotStrategy<K>
      • org.apache.flink.state.forst.snapshot.ForStIncrementalSnapshotStrategy<K>
  • org.apache.flink.state.forst.snapshot.ForStSnapshotStrategyBase.ForStNativeSnapshotResources (implements org.apache.flink.runtime.state.SnapshotResources)
  • org.apache.flink.state.forst.snapshot.ForStSnapshotStrategyBase.ForStSnapshotOperation (implements org.apache.flink.runtime.state.SnapshotStrategy.SnapshotResultSupplier<S>)
  • org.apache.flink.state.forst.snapshot.ForStSnapshotStrategyBase.PreviousSnapshot
  • org.apache.flink.state.forst.snapshot.ForStSnapshotUtil
  • org.apache.flink.state.forst.ForStStateBackendFactory (implements org.apache.flink.runtime.state.StateBackendFactory<T>)
  • org.apache.flink.state.forst.datatransfer.ForStStateDataTransfer (implements java.io.Closeable)
  • org.apache.flink.state.forst.ForStStateExecutor (implements org.apache.flink.runtime.asyncprocessing.StateExecutor)
  • org.apache.flink.state.forst.ForStStateRequestClassifier (implements org.apache.flink.runtime.asyncprocessing.AsyncRequestContainer<REQUEST>)
  • org.apache.flink.state.forst.ForStWriteBatchOperation (implements org.apache.flink.state.forst.ForStDBOperation)
  • java.io.InputStream (implements java.io.Closeable)
    • org.apache.flink.core.fs.FSDataInputStream
      • org.apache.flink.state.forst.fs.ByteBufferReadableFSDataInputStream
      • org.apache.flink.state.forst.fs.cache.CachedDataInputStream (implements org.apache.flink.core.fs.ByteBufferReadable)
  • org.apache.flink.state.forst.ListDelimitedSerializer
  • org.apache.flink.state.forst.fs.filemapping.MappingEntrySource
    • org.apache.flink.state.forst.fs.filemapping.FileBackedMappingEntrySource
    • org.apache.flink.state.forst.fs.filemapping.HandleBackedMappingEntrySource
  • java.io.OutputStream (implements java.io.Closeable, java.io.Flushable)
    • org.apache.flink.core.fs.FSDataOutputStream
      • org.apache.flink.state.forst.fs.ByteBufferWritableFSDataOutputStream
      • org.apache.flink.state.forst.fs.cache.CachedDataOutputStream
      • org.apache.flink.core.fs.FSDataOutputStreamWrapper (implements org.apache.flink.util.WrappingProxy<T>)
        • org.apache.flink.state.forst.fs.filemapping.FSDataOutputStreamWithEntry
  • org.apache.flink.runtime.asyncprocessing.ReferenceCounted<ReleaseHelper>
    • org.apache.flink.state.forst.fs.cache.FileCacheEntry
    • org.apache.flink.state.forst.fs.filemapping.MappingEntry
  • org.apache.flink.state.forst.fs.cache.SizeBasedCacheLimitPolicy (implements org.apache.flink.state.forst.fs.cache.CacheLimitPolicy)
  • org.apache.flink.state.forst.fs.cache.SpaceBasedCacheLimitPolicy (implements org.apache.flink.state.forst.fs.cache.CacheLimitPolicy)
  • org.apache.flink.state.forst.StateHandleTransferSpec
  • org.apache.flink.state.forst.fs.StringifiedForStFileSystem
  • org.apache.flink.state.forst.sync.TreeOrderedSetCache (implements org.apache.flink.state.forst.sync.ForStDBCachingPriorityQueueSet.OrderedByteArraySetCache)

Interface Hierarchy

• java.lang.AutoCloseable
  • org.apache.flink.state.forst.restore.ForStRestoreOperation (also extends org.apache.flink.runtime.state.RestoreOperation<R>)
• org.apache.flink.state.forst.fs.cache.CacheLimitPolicy
• org.apache.flink.state.forst.sync.ForStDBCachingPriorityQueueSet.OrderedByteArraySetCache
• org.apache.flink.state.forst.ForStDBOperation
• org.apache.flink.state.forst.ForStInnerTable<K,N,V>
• org.apache.flink.runtime.state.RestoreOperation<R>
  • org.apache.flink.state.forst.restore.ForStRestoreOperation (also extends java.lang.AutoCloseable)
• java.io.Serializable
  • org.apache.flink.state.forst.ForStMemoryControllerUtils.ForStMemoryFactory
  • org.apache.flink.state.forst.ForStOptionsFactory
    • org.apache.flink.state.forst.ConfigurableForStOptionsFactory

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.apache.flink.state.forst.fs.cache.FileCacheEntry.EntryStatus
    • org.apache.flink.state.forst.fs.filemapping.FileOwnership
    • org.apache.flink.state.forst.ForStProperty
    • org.apache.flink.state.forst.ForStStateBackend.PriorityQueueStateType (implements org.apache.flink.configuration.DescribedEnum)
    • org.apache.flink.state.forst.ForStStateRequestType