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

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • org.apache.flink.runtime.state.AbstractChannelStateHandle<Info> (implements org.apache.flink.runtime.state.StateObject)
    • org.apache.flink.runtime.state.InputChannelStateHandle
    • org.apache.flink.runtime.state.ResultSubpartitionStateHandle
  • org.apache.flink.runtime.state.AbstractChannelStateHandle.StateContentMetaInfo
  • 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.SnapshotStrategy<S>)
  • org.apache.flink.runtime.state.AbstractKeyedStateBackendBuilder<K> (implements org.apache.flink.runtime.state.StateBackendBuilder<T,E>)
  • org.apache.flink.runtime.state.AbstractSnapshotStrategy<T> (implements org.apache.flink.runtime.state.SnapshotStrategy<S>)
  • org.apache.flink.runtime.state.AbstractStateBackend (implements java.io.Serializable, org.apache.flink.runtime.state.StateBackend)
  • org.apache.flink.runtime.state.AsyncSnapshotCallable<T> (implements java.util.concurrent.Callable<V>)
  • 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.api.common.typeutils.CompositeTypeSerializerSnapshot<T,S> (implements org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<T>)
    • org.apache.flink.runtime.state.ArrayListSerializerSnapshot<T>
  • 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.DefaultOperatorStateBackendBuilder (implements org.apache.flink.runtime.state.StateBackendBuilder<T,E>)
  • org.apache.flink.runtime.state.DirectoryKeyedStateHandle (implements org.apache.flink.runtime.state.KeyedStateHandle)
    • org.apache.flink.runtime.state.IncrementalLocalKeyedStateHandle (implements org.apache.flink.runtime.state.IncrementalKeyedStateHandle)
  • 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>)
  • java.util.concurrent.FutureTask<V> (implements java.util.concurrent.RunnableFuture<V>)
    • org.apache.flink.runtime.state.AsyncSnapshotCallable.AsyncSnapshotTask
  • org.apache.flink.runtime.state.HeapBroadcastState<K,V> (implements org.apache.flink.runtime.state.BackendWritableBroadcastState<K,V>)
  • org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle (implements org.apache.flink.runtime.state.IncrementalKeyedStateHandle)
  • java.io.InputStream (implements java.io.Closeable)
    • org.apache.flink.runtime.state.BoundedInputStream
  • org.apache.flink.runtime.state.KeyGroupPartitioner<T>
  • 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.OperatorStateHandle.StateMetaInfo (implements java.io.Serializable)
  • org.apache.flink.runtime.state.OperatorStateRestoreOperation (implements org.apache.flink.runtime.state.RestoreOperation<R>)
  • 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.PartitionableListState<S> (implements org.apache.flink.api.common.state.ListState<T>)
  • org.apache.flink.runtime.state.PlaceholderStreamStateHandle (implements org.apache.flink.runtime.state.StreamStateHandle)
  • org.apache.flink.runtime.state.RegisteredStateMetaInfoBase
    • org.apache.flink.runtime.state.RegisteredBroadcastStateBackendMetaInfo<K,V>
    • org.apache.flink.runtime.state.RegisteredKeyValueStateBackendMetaInfo<N,S>
    • org.apache.flink.runtime.state.RegisteredOperatorStateBackendMetaInfo<S>
    • org.apache.flink.runtime.state.RegisteredPriorityQueueStateBackendMetaInfo<T>
  • 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.api.common.typeutils.SimpleTypeSerializerSnapshot<T> (implements org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<T>)
    • org.apache.flink.runtime.state.JavaSerializer.JavaSerializerSnapshot<T>
    • org.apache.flink.runtime.state.VoidNamespaceSerializer.VoidNamespaceSerializerSnapshot
  • 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.StateEntry.SimpleStateEntry<K,N,S> (implements org.apache.flink.runtime.state.StateEntry<K,N,S>)
  • 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.StateSerializerProvider<T>
  • org.apache.flink.runtime.state.StateSnapshotContextSynchronousImpl (implements org.apache.flink.runtime.state.StateSnapshotContext)
  • org.apache.flink.runtime.state.StateSnapshotTransformers
  • org.apache.flink.runtime.state.StateSnapshotTransformers.ListStateSnapshotTransformer<T> (implements org.apache.flink.runtime.state.StateSnapshotTransformer<T>)
  • org.apache.flink.runtime.state.StateSnapshotTransformers.MapStateSnapshotTransformer<K,V> (implements org.apache.flink.runtime.state.StateSnapshotTransformer<T>)
  • org.apache.flink.runtime.state.StateSnapshotTransformers.StateSnapshotTransformFactoryWrapAdaptor<S,T> (implements org.apache.flink.runtime.state.StateSnapshotTransformer.StateSnapshotTransformFactory<T>)
    • org.apache.flink.runtime.state.StateSnapshotTransformers.ListStateSnapshotTransformFactory<T>
    • org.apache.flink.runtime.state.StateSnapshotTransformers.MapStateSnapshotTransformFactory<K,V>
  • 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)
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • java.io.IOException
        • org.apache.flink.runtime.state.BackendBuildingException
  • 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> (implements org.apache.flink.api.common.typeutils.TypeSerializerConfigSnapshot.SelfResolvingTypeSerializer<E>)
    • org.apache.flink.api.common.typeutils.base.TypeSerializerSingleton<T>
      • org.apache.flink.runtime.state.JavaSerializer<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.SnapshotStrategy<S>)
  • org.apache.flink.runtime.state.TaskStateManager (also extends org.apache.flink.runtime.state.CheckpointListener)
• org.apache.flink.runtime.state.CheckpointListener
  • org.apache.flink.runtime.state.TaskStateManager (also extends java.lang.AutoCloseable)
• org.apache.flink.runtime.state.CheckpointStorageCoordinatorView
  • org.apache.flink.runtime.state.CheckpointStorage (also extends org.apache.flink.runtime.state.CheckpointStorageWorkerView)
• org.apache.flink.runtime.state.CheckpointStorageWorkerView
  • org.apache.flink.runtime.state.CheckpointStorage (also extends org.apache.flink.runtime.state.CheckpointStorageCoordinatorView)
• 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.KeyedStateFactory, org.apache.flink.runtime.state.PriorityQueueSetFactory)
  • org.apache.flink.runtime.state.OperatorStateBackend (also extends java.io.Closeable, org.apache.flink.api.common.state.OperatorStateStore, org.apache.flink.runtime.state.SnapshotStrategy<S>)
• org.apache.flink.runtime.state.InternalPriorityQueue<T>
  • org.apache.flink.runtime.state.KeyGroupedInternalPriorityQueue<T>
• java.lang.Iterable<T>
  • org.apache.flink.runtime.state.KeyGroupsList
• org.apache.flink.runtime.state.Keyed<K>
• org.apache.flink.runtime.state.KeyedStateBackend.KeySelectionListener<K>
• org.apache.flink.runtime.state.KeyedStateFactory
  • org.apache.flink.runtime.state.KeyedStateBackend<K> (also extends org.apache.flink.util.Disposable, org.apache.flink.runtime.state.PriorityQueueSetFactory)
• org.apache.flink.runtime.state.KeyedStateFunction<K,S>
• org.apache.flink.runtime.state.KeyExtractorFunction<T>
• org.apache.flink.runtime.state.KeyGroupPartitioner.ElementReaderFunction<T>
• org.apache.flink.runtime.state.KeyGroupPartitioner.ElementWriterFunction<T>
• org.apache.flink.runtime.state.KeyGroupPartitioner.KeyGroupElementsConsumer<T>
• 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.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.SnapshotStrategy<S>)
• org.apache.flink.runtime.state.PriorityComparable<T>
• org.apache.flink.runtime.state.PriorityComparator<T>
• org.apache.flink.runtime.state.PriorityQueueSetFactory
  • org.apache.flink.runtime.state.KeyedStateBackend<K> (also extends org.apache.flink.util.Disposable, org.apache.flink.runtime.state.KeyedStateFactory)
• org.apache.flink.runtime.state.RestoreOperation<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.IncrementalKeyedStateHandle
    • 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.SnapshotStrategy<S>
  • 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.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.StateBackendBuilder<T,E>
• org.apache.flink.runtime.state.StateBackendFactory<T>
• org.apache.flink.runtime.state.StateEntry<K,N,S>
• org.apache.flink.runtime.state.StateSnapshot
• org.apache.flink.runtime.state.StateSnapshot.StateKeyGroupWriter
• org.apache.flink.runtime.state.StateSnapshotKeyGroupReader
• org.apache.flink.runtime.state.StateSnapshotRestore
• org.apache.flink.runtime.state.StateSnapshotTransformer<T>
  • org.apache.flink.runtime.state.StateSnapshotTransformer.CollectionStateSnapshotTransformer<T>
• org.apache.flink.runtime.state.StateSnapshotTransformer.StateSnapshotTransformFactory<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.CheckpointedStateScope
    • org.apache.flink.runtime.state.StateSnapshotTransformer.CollectionStateSnapshotTransformer.TransformStrategy
    • org.apache.flink.runtime.state.OperatorStateHandle.Mode