Hierarchy For Package org.apache.flink.runtime.state

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • org.apache.flink.runtime.state.AbstractKeyedStateBackend<K> (implements org.apache.flink.runtime.state.CheckpointListener, java.io.Closeable, org.apache.flink.runtime.state.KeyedStateBackend<K>, org.apache.flink.runtime.state.Snapshotable<S,R>)
  • org.apache.flink.runtime.state.AbstractStateBackend (implements java.io.Serializable, org.apache.flink.runtime.state.StateBackend)
  • org.apache.flink.runtime.state.ChainedStateHandle<T> (implements org.apache.flink.runtime.state.StateObject)
  • org.apache.flink.runtime.state.CheckpointStorageLocationReference (implements java.io.Serializable)
  • org.apache.flink.runtime.state.CheckpointStreamWithResultProvider.PrimaryAndSecondaryStream (implements org.apache.flink.runtime.state.CheckpointStreamWithResultProvider)
  • org.apache.flink.runtime.state.CheckpointStreamWithResultProvider.PrimaryStreamOnly (implements org.apache.flink.runtime.state.CheckpointStreamWithResultProvider)
  • org.apache.flink.runtime.state.DefaultKeyedStateStore (implements org.apache.flink.api.common.state.KeyedStateStore)
  • org.apache.flink.runtime.state.DefaultOperatorStateBackend (implements org.apache.flink.runtime.state.OperatorStateBackend)
  • org.apache.flink.runtime.state.DirectoryKeyedStateHandle (implements org.apache.flink.runtime.state.KeyedStateHandle)
    • org.apache.flink.runtime.state.IncrementalLocalKeyedStateHandle
  • org.apache.flink.runtime.state.DirectoryStateHandle (implements org.apache.flink.runtime.state.StateObject)
  • org.apache.flink.runtime.state.DoneFuture<T> (implements java.util.concurrent.RunnableFuture<V>)
  • org.apache.flink.runtime.state.HeapBroadcastState<K,V> (implements org.apache.flink.runtime.state.BackendWritableBroadcastState<K,V>)
  • org.apache.flink.runtime.state.IncrementalKeyedStateHandle (implements org.apache.flink.runtime.state.KeyedStateHandle)
  • java.io.InputStream (implements java.io.Closeable)
    • org.apache.flink.runtime.state.BoundedInputStream
  • org.apache.flink.runtime.state.KeyedBackendStateMetaInfoSnapshotReaderWriters
  • org.apache.flink.runtime.state.KeyedStateFunction<K,S>
  • org.apache.flink.runtime.state.KeyGroupRange (implements org.apache.flink.runtime.state.KeyGroupsList, java.io.Serializable)
  • org.apache.flink.runtime.state.KeyGroupRangeAssignment
  • org.apache.flink.runtime.state.KeyGroupRangeOffsets (implements java.lang.Iterable<T>, java.io.Serializable)
  • org.apache.flink.runtime.state.KeyGroupsStateHandle (implements org.apache.flink.runtime.state.KeyedStateHandle, org.apache.flink.runtime.state.StreamStateHandle)
  • org.apache.flink.runtime.state.LocalRecoveryConfig
  • org.apache.flink.runtime.state.LocalRecoveryDirectoryProviderImpl (implements org.apache.flink.runtime.state.LocalRecoveryDirectoryProvider)
  • org.apache.flink.runtime.state.NoOpTaskLocalStateStoreImpl (implements org.apache.flink.runtime.state.OwnedTaskLocalStateStore)
  • org.apache.flink.runtime.state.OperatorBackendStateMetaInfoSnapshotReaderWriters
  • org.apache.flink.runtime.state.OperatorBackendStateMetaInfoSnapshotReaderWriters.AbstractBroadcastStateMetaInfoReader<K,V> (implements org.apache.flink.runtime.state.OperatorBackendStateMetaInfoSnapshotReaderWriters.BroadcastStateMetaInfoReader<K,V>)
    • org.apache.flink.runtime.state.OperatorBackendStateMetaInfoSnapshotReaderWriters.BroadcastStateMetaInfoReaderV3<K,V>
  • org.apache.flink.runtime.state.OperatorBackendStateMetaInfoSnapshotReaderWriters.AbstractBroadcastStateMetaInfoWriter<K,V> (implements org.apache.flink.runtime.state.OperatorBackendStateMetaInfoSnapshotReaderWriters.BroadcastStateMetaInfoWriter)
    • org.apache.flink.runtime.state.OperatorBackendStateMetaInfoSnapshotReaderWriters.BroadcastStateMetaInfoWriterV3<K,V>
  • org.apache.flink.runtime.state.OperatorBackendStateMetaInfoSnapshotReaderWriters.AbstractOperatorBackendStateMetaInfoReader<S> (implements org.apache.flink.runtime.state.OperatorBackendStateMetaInfoSnapshotReaderWriters.OperatorBackendStateMetaInfoReader<S>)
    • org.apache.flink.runtime.state.OperatorBackendStateMetaInfoSnapshotReaderWriters.OperatorBackendStateMetaInfoReaderV1<S>
    • org.apache.flink.runtime.state.OperatorBackendStateMetaInfoSnapshotReaderWriters.OperatorBackendStateMetaInfoReaderV2<S>
  • org.apache.flink.runtime.state.OperatorBackendStateMetaInfoSnapshotReaderWriters.AbstractOperatorBackendStateMetaInfoWriter<S> (implements org.apache.flink.runtime.state.OperatorBackendStateMetaInfoSnapshotReaderWriters.OperatorBackendStateMetaInfoWriter)
    • org.apache.flink.runtime.state.OperatorBackendStateMetaInfoSnapshotReaderWriters.OperatorBackendStateMetaInfoWriterV1<S>
    • org.apache.flink.runtime.state.OperatorBackendStateMetaInfoSnapshotReaderWriters.OperatorBackendStateMetaInfoWriterV2<S>
  • org.apache.flink.runtime.state.OperatorStateHandle.StateMetaInfo (implements java.io.Serializable)
  • org.apache.flink.runtime.state.OperatorStreamStateHandle (implements org.apache.flink.runtime.state.OperatorStateHandle)
  • java.io.OutputStream (implements java.io.Closeable, java.io.Flushable)
    • org.apache.flink.core.fs.FSDataOutputStream
      • org.apache.flink.runtime.state.CheckpointMetadataOutputStream
      • org.apache.flink.runtime.state.CheckpointStreamFactory.CheckpointStateOutputStream
        • org.apache.flink.runtime.state.DuplicatingCheckpointOutputStream
    • org.apache.flink.runtime.state.NonClosingCheckpointOutputStream<T>
      • org.apache.flink.runtime.state.KeyedStateCheckpointOutputStream
      • org.apache.flink.runtime.state.OperatorStateCheckpointOutputStream
  • org.apache.flink.runtime.state.PlaceholderStreamStateHandle (implements org.apache.flink.runtime.state.StreamStateHandle)
  • org.apache.flink.runtime.state.RegisteredBroadcastBackendStateMetaInfo<K,V>
  • org.apache.flink.runtime.state.RegisteredBroadcastBackendStateMetaInfo.Snapshot<K,V>
  • org.apache.flink.runtime.state.RegisteredKeyedBackendStateMetaInfo<N,S>
  • org.apache.flink.runtime.state.RegisteredKeyedBackendStateMetaInfo.Snapshot<N,S>
  • org.apache.flink.runtime.state.RegisteredOperatorBackendStateMetaInfo<S>
  • org.apache.flink.runtime.state.RegisteredOperatorBackendStateMetaInfo.Snapshot<S>
  • org.apache.flink.runtime.state.RetrievableStreamStateHandle<T> (implements java.io.Closeable, org.apache.flink.runtime.state.RetrievableStateHandle<T>, org.apache.flink.runtime.state.StreamStateHandle)
  • org.apache.flink.runtime.state.SharedStateRegistry (implements java.lang.AutoCloseable)
  • org.apache.flink.runtime.state.SharedStateRegistry.Result
  • org.apache.flink.runtime.state.SnapshotDirectory
  • org.apache.flink.runtime.state.SnapshotResult<T> (implements org.apache.flink.runtime.state.StateObject)
  • org.apache.flink.runtime.state.StateBackendLoader
  • org.apache.flink.runtime.state.StateInitializationContextImpl (implements org.apache.flink.runtime.state.StateInitializationContext)
  • org.apache.flink.runtime.state.StatePartitionStreamProvider
    • org.apache.flink.runtime.state.KeyGroupStatePartitionStreamProvider
  • org.apache.flink.runtime.state.StateSnapshotContextSynchronousImpl (implements java.io.Closeable, org.apache.flink.runtime.state.StateSnapshotContext)
  • org.apache.flink.runtime.state.StateUtil
  • org.apache.flink.runtime.state.StreamCompressionDecorator (implements java.io.Serializable)
    • org.apache.flink.runtime.state.SnappyStreamCompressionDecorator
    • org.apache.flink.runtime.state.UncompressedStreamCompressionDecorator
  • org.apache.flink.util.StringBasedID (implements java.io.Serializable)
    • org.apache.flink.runtime.state.SharedStateRegistryKey
    • org.apache.flink.runtime.state.StateHandleID
  • org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager
  • org.apache.flink.runtime.state.TaskLocalStateStoreImpl (implements org.apache.flink.runtime.state.OwnedTaskLocalStateStore)
  • org.apache.flink.runtime.state.TaskStateManagerImpl (implements org.apache.flink.runtime.state.TaskStateManager)
  • org.apache.flink.api.common.typeinfo.TypeInformation<T> (implements java.io.Serializable)
    • org.apache.flink.runtime.state.VoidNamespaceTypeInfo
  • org.apache.flink.api.common.typeutils.TypeSerializer<T> (implements java.io.Serializable)
    • org.apache.flink.runtime.state.ArrayListSerializer<T>
    • org.apache.flink.api.common.typeutils.base.TypeSerializerSingleton<T>
      • org.apache.flink.runtime.state.VoidNamespaceSerializer
  • org.apache.flink.core.io.VersionedIOReadableWritable (implements org.apache.flink.core.io.IOReadableWritable, org.apache.flink.core.io.Versioned)
    • org.apache.flink.runtime.state.KeyedBackendSerializationProxy<K>
    • org.apache.flink.runtime.state.OperatorBackendSerializationProxy
  • org.apache.flink.runtime.state.VoidNamespace

Interface Hierarchy

• java.lang.AutoCloseable
  • java.io.Closeable
    • org.apache.flink.runtime.state.CheckpointStreamWithResultProvider
    • org.apache.flink.runtime.state.OperatorStateBackend (also extends org.apache.flink.util.Disposable, org.apache.flink.api.common.state.OperatorStateStore, org.apache.flink.runtime.state.Snapshotable<S,R>)
• org.apache.flink.runtime.state.CheckpointListener
  • org.apache.flink.runtime.state.TaskStateManager
• org.apache.flink.runtime.state.CheckpointStorage
• org.apache.flink.runtime.state.CheckpointStreamFactory
  • org.apache.flink.runtime.state.CheckpointStorageLocation
• org.apache.flink.runtime.state.ConfigurableStateBackend
• org.apache.flink.util.Disposable
  • org.apache.flink.runtime.state.KeyedStateBackend<K> (also extends org.apache.flink.runtime.state.heap.InternalKeyContext<K>)
  • org.apache.flink.runtime.state.OperatorStateBackend (also extends java.io.Closeable, org.apache.flink.api.common.state.OperatorStateStore, org.apache.flink.runtime.state.Snapshotable<S,R>)
• org.apache.flink.runtime.state.heap.InternalKeyContext<K>
  • org.apache.flink.runtime.state.KeyedStateBackend<K> (also extends org.apache.flink.util.Disposable)
• java.lang.Iterable<T>
  • org.apache.flink.runtime.state.KeyGroupsList
• org.apache.flink.runtime.state.KeyedBackendStateMetaInfoSnapshotReaderWriters.KeyedBackendStateMetaInfoReader<N,S>
• org.apache.flink.runtime.state.KeyedBackendStateMetaInfoSnapshotReaderWriters.KeyedBackendStateMetaInfoWriter
• org.apache.flink.runtime.state.ManagedInitializationContext
  • org.apache.flink.runtime.state.FunctionInitializationContext
    • org.apache.flink.runtime.state.StateInitializationContext
• org.apache.flink.runtime.state.ManagedSnapshotContext
  • org.apache.flink.runtime.state.FunctionSnapshotContext
    • org.apache.flink.runtime.state.StateSnapshotContext
• org.apache.flink.runtime.state.OperatorBackendStateMetaInfoSnapshotReaderWriters.BroadcastStateMetaInfoReader<K,V>
• org.apache.flink.runtime.state.OperatorBackendStateMetaInfoSnapshotReaderWriters.BroadcastStateMetaInfoWriter
• org.apache.flink.runtime.state.OperatorBackendStateMetaInfoSnapshotReaderWriters.OperatorBackendStateMetaInfoReader<S>
• org.apache.flink.runtime.state.OperatorBackendStateMetaInfoSnapshotReaderWriters.OperatorBackendStateMetaInfoWriter
• org.apache.flink.api.common.state.OperatorStateStore
  • org.apache.flink.runtime.state.OperatorStateBackend (also extends java.io.Closeable, org.apache.flink.util.Disposable, org.apache.flink.runtime.state.Snapshotable<S,R>)
• java.io.Serializable
  • org.apache.flink.runtime.state.CompletedCheckpointStorageLocation
  • org.apache.flink.runtime.state.LocalRecoveryDirectoryProvider
  • org.apache.flink.runtime.state.StateBackend
  • org.apache.flink.runtime.state.StateObject
    • org.apache.flink.runtime.state.CompositeStateHandle
      • org.apache.flink.runtime.state.KeyedStateHandle
    • org.apache.flink.runtime.state.RetrievableStateHandle<T>
    • org.apache.flink.runtime.state.StreamStateHandle
      • org.apache.flink.runtime.state.OperatorStateHandle
• org.apache.flink.runtime.state.SharedStateRegistryFactory
• org.apache.flink.runtime.state.Snapshotable<S,R>
  • org.apache.flink.runtime.state.OperatorStateBackend (also extends java.io.Closeable, org.apache.flink.util.Disposable, org.apache.flink.api.common.state.OperatorStateStore)
• org.apache.flink.runtime.state.SnapshotStrategy<S>
• org.apache.flink.api.common.state.State
  • org.apache.flink.api.common.state.ReadOnlyBroadcastState<K,V>
    • org.apache.flink.api.common.state.BroadcastState<K,V>
      • org.apache.flink.runtime.state.BackendWritableBroadcastState<K,V>
• org.apache.flink.runtime.state.StateBackendFactory<T>
• org.apache.flink.runtime.state.StateTransformationFunction<S,T>
• org.apache.flink.runtime.state.TaskLocalStateStore
  • org.apache.flink.runtime.state.OwnedTaskLocalStateStore

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.apache.flink.runtime.state.OperatorStateHandle.Mode
    • org.apache.flink.runtime.state.CheckpointedStateScope