Uses of Package
org.apache.flink.core.fs

Packages that use org.apache.flink.core.fs

Package	Description
org.apache.flink.api.common.cache
org.apache.flink.api.common.functions.util
org.apache.flink.api.common.io
org.apache.flink.api.common.serialization
org.apache.flink.core.fs
org.apache.flink.core.fs.local
org.apache.flink.util

Classes in org.apache.flink.core.fs used by org.apache.flink.api.common.cache

Class	Description
Path	Names a file or directory in a FileSystem.

Classes in org.apache.flink.core.fs used by org.apache.flink.api.common.functions.util

Class	Description
Path	Names a file or directory in a FileSystem.

Classes in org.apache.flink.core.fs used by org.apache.flink.api.common.io

Class	Description
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.
FileStatus	Interface that represents the client side information for a file independent of the file system.
FileSystem	Abstract base class of all file systems used by Flink.
FileSystem.WriteMode	The possible write modes.
FSDataInputStream	Interface for a data input stream to a file on a FileSystem.
FSDataOutputStream	An output stream to a file that is created via a FileSystem.
Path	Names a file or directory in a FileSystem.

Classes in org.apache.flink.core.fs used by org.apache.flink.api.common.serialization

Class	Description
FSDataOutputStream	An output stream to a file that is created via a FileSystem.

Classes in org.apache.flink.core.fs used by org.apache.flink.core.fs

Class	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.
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.
FileStatus	Interface that represents the client side information for a file independent of the file system.
FileSystem	Abstract base class of all file systems used by Flink.
FileSystem.WriteMode	The possible write modes.
FileSystemFactory	A factory to create file systems.
FileSystemKind	An enumeration defining the kind and characteristics of a FileSystem.
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.
ICloseableRegistry	This class allows to register instances of Closeable, which are all closed if this registry is closed.
IFileSystem	Interface of all file systems used by Flink.
LimitedConnectionsFileSystem.ConnectionLimitingSettings	A simple configuration data object capturing the settings for limited connections.
LimitedConnectionsFileSystem.StreamTimeoutException	A special IOException, indicating a timeout in the data output stream.
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.
PathsCopyingFileSystem	An interface marking that given FileSystem have an optimised path for copying paths instead of using FSDataOutputStream or FSDataInputStream.
PathsCopyingFileSystem.CopyRequest	A pair of source and destination to duplicate a file.
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.
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.
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.
WrappingProxyCloseable	WrappingProxy for Closeable that is also closeable.

Classes in org.apache.flink.core.fs used by org.apache.flink.core.fs.local

Class	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.
CommitterFromPersistRecoverableFsDataOutputStream	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.
FileStatus	Interface that represents the client side information for a file independent of the file system.
FileSystem	Abstract base class of all file systems used by Flink.
FileSystem.WriteMode	The possible write modes.
FileSystemFactory	A factory to create file systems.
FSDataInputStream	Interface for a data input stream to a file on a FileSystem.
FSDataOutputStream	An output stream to a file that is created via a FileSystem.
IFileSystem	Interface of all file systems used by Flink.
LocatedFileStatus	A LocatedFileStatus is a FileStatus that contains additionally the location information of the file directly.
Path	Names a file or directory in a FileSystem.
RecoverableFsDataOutputStream	An output stream to a file system that can be recovered at well defined points.
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.

Classes in org.apache.flink.core.fs used by org.apache.flink.util

Class	Description
Path	Names a file or directory in a FileSystem.