Package org.apache.flink.core.fs

Interface Summary

Interface	Description
BlockLocation	A BlockLocation lists hosts, offset and length of block.
ByteBufferReadable	An interface mark that a filesystem supports to read bytes from a ByteBuffer and its given position.
DuplicatingFileSystem	An extension interface for FileSystems that can perform cheap DFS side duplicate operation.
DuplicatingFileSystem.CopyRequest	A pair of source and destination to duplicate a file.
EntropyInjectingFileSystem	An interface to be implemented by a FileSystem that is aware of entropy injection.
FileStatus	Interface that represents the client side information for a file independent of the file system.
FileSystemFactory	A factory to create file systems.
LocatedFileStatus	A LocatedFileStatus is a FileStatus that contains additionally the location information of the file directly.
RecoverableFsDataOutputStream.Committer	A committer can publish the file of a stream that was closed.
RecoverableWriter	The RecoverableWriter creates and recovers RecoverableFsDataOutputStream.
RecoverableWriter.CommitRecoverable	A handle to an in-progress stream with a defined and persistent amount of data.
RecoverableWriter.ResumeRecoverable	A handle to an in-progress stream with a defined and persistent amount of data.
WrappingProxyCloseable<T extends Closeable>	WrappingProxy for Closeable that is also closeable.

Class Summary

Class	Description
AutoCloseableRegistry	This class allows to register instances of AutoCloseable, which are all closed if this registry is closed.
BackPressuringExecutor	An executor decorator that allows only a certain number of concurrent executions.
ByteBufferReadableClosingFSDataInputStream	A ClosingFSDataInputStream which is ByteBufferReadable.
CloseableRegistry	This class allows to register instances of Closeable, which are all closed if this registry is closed.
ClosingFSDataInputStream	This class is a WrappingProxy for FSDataInputStream that is used to implement a safety net against unclosed streams.
ClosingFSDataOutputStream	This class is a WrappingProxy for FSDataOutputStream that is used to implement a safety net against unclosed streams.
CommitterFromPersistRecoverableFsDataOutputStream<RESUME_RECOVERABLE extends RecoverableWriter.ResumeRecoverable>	RecoverableFsDataOutputStream with fixed implementation of CommitterFromPersistRecoverableFsDataOutputStream.closeForCommit() that is based on using CommitterFromPersistRecoverableFsDataOutputStream.persist() to ensure durability and creates the RecoverableFsDataOutputStream.Committer from the corresponding RecoverableWriter.ResumeRecoverable.
ConnectionLimitingFactory	A wrapping factory that adds a LimitedConnectionsFileSystem to a file system.
EntropyInjector	This class offers utilities for entropy injection for FileSystems that implement EntropyInjectingFileSystem.
FileInputSplit	A file input split provides information on a particular part of a file, possibly hosted on a distributed file system and replicated among several hosts.
FileSystem	Abstract base class of all file systems used by Flink.
FileSystemSafetyNet	The FileSystemSafetyNet can be used to guard a thread against FileSystem stream resource leaks.
FSDataInputStream	Interface for a data input stream to a file on a FileSystem.
FSDataInputStreamWrapper	Simple forwarding wrapper around FSDataInputStream.
FSDataOutputStream	An output stream to a file that is created via a FileSystem.
FSDataOutputStreamWrapper	Simple forwarding wrapper around FSDataInputStream.
LimitedConnectionsFileSystem	A file system that limits the number of concurrently open input streams, output streams, and total streams for a target file system.
LimitedConnectionsFileSystem.ConnectionLimitingSettings	A simple configuration data object capturing the settings for limited connections.
OffsetAwareOutputStream	An OutputStream that keeps track of its current length.
OutputStreamAndPath	An output stream and a path.
Path	Names a file or directory in a FileSystem.
PluginFileSystemFactory	A wrapper around FileSystemFactory that ensures the plugin classloader is used for all FileSystem operations.
RecoverableFsDataOutputStream	An output stream to a file system that can be recovered at well defined points.
RefCountedBufferingFileStream	A RefCountedFileWithStream that also uses an in-memory buffer for buffering small writes.
RefCountedFile	A reference counted file which is deleted as soon as no caller holds a reference to the wrapped File.
RefCountedFileWithStream	A reference counted file which is deleted as soon as no caller holds a reference to the wrapped File.
RefCountedFSOutputStream	A FSDataOutputStream with the RefCounted functionality.
RefCountedTmpFileCreator	A utility class that creates local reference counted files that serve as temporary files.
SafetyNetCloseableRegistry	This implementation of an AbstractAutoCloseableRegistry registers WrappingProxyCloseable.
SafetyNetWrapperFileSystem	This is a WrappingProxy around FileSystem which (i) wraps all opened streams as ClosingFSDataInputStream or ClosingFSDataOutputStream and (ii) registers them to a SafetyNetCloseableRegistry.

Enum Summary

Enum	Description
FileSystem.WriteMode	The possible write modes.
FileSystemKind	An enumeration defining the kind and characteristics of a FileSystem.

Exception Summary

Exception	Description
LimitedConnectionsFileSystem.StreamTimeoutException	A special IOException, indicating a timeout in the data output stream.
UnsupportedFileSystemSchemeException	An exception to indicate that a specific file system scheme is not supported.