Package org.apache.flink.runtime.state.filesystem

Class Summary

Class	Description
AbstractFileStateBackend	Deprecated. State backends should no longer implement CheckpointStorage functionality.
AbstractFsCheckpointStorageAccess	An implementation of durable checkpoint storage to file systems.
FileBasedStateOutputStream	A CheckpointStateOutputStream that writes into a specified file and returns a FileStateHandle upon closing.
FileStateHandle	StreamStateHandle for state that was written to a file stream.
FsCheckpointMetadataOutputStream	A CheckpointMetadataOutputStream that writes a specified file and directory, and returns a FsCompletedCheckpointStorageLocation upon closing.
FsCheckpointStateToolset	An implementation of CheckpointStateToolset that does file based duplicating with as DuplicatingFileSystem.
FsCheckpointStorageAccess	An implementation of durable checkpoint storage to file systems.
FsCheckpointStorageLocation	A storage location for checkpoints on a file system.
FsCheckpointStreamFactory	A CheckpointStreamFactory that produces streams that write to a FileSystem.
FsCheckpointStreamFactory.FsCheckpointStateOutputStream	A CheckpointStateOutputStream that writes into a file and returns a StreamStateHandle upon closing.
FsCompletedCheckpointStorageLocation	A CompletedCheckpointStorageLocation that resides on a file system.
FSDataOutputStreamWrapper	Implementation of MetadataOutputStreamWrapper encapsulates the FSDataOutputStream for FsCheckpointMetadataOutputStream.
FsStateBackend	Deprecated.
FsStateBackendFactory	A factory that creates an FsStateBackend from a configuration.
MetadataOutputStreamWrapper	The wrapper manages metadata output stream close and commit.
RecoverableStreamWrapper	Implementation of MetadataOutputStreamWrapper encapsulates the RecoverableFsDataOutputStream for FsCheckpointMetadataOutputStream.
RelativeFileStateHandle	A StreamStateHandle for state that was written to a file stream.