Uses of Package
org.apache.flink.core.fs
-
Classes in org.apache.flink.core.fs used by org.apache.flink.api.common.cache Class Description Path Names a file or directory in aFileSystem. -
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 aFileSystem. -
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 aFileSystem.FSDataOutputStream An output stream to a file that is created via aFileSystem.Path Names a file or directory in aFileSystem. -
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 aFileSystem. -
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.ClosingFSDataInputStream This class is aWrappingProxyforFSDataInputStreamthat is used to implement a safety net against unclosed streams.ClosingFSDataOutputStream This class is aWrappingProxyforFSDataOutputStreamthat is used to implement a safety net against unclosed streams.DuplicatingFileSystem.CopyRequest A pair of source and destination to duplicate a file.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 aFileSystem.FSDataInputStream Interface for a data input stream to a file on aFileSystem.FSDataInputStreamWrapper Simple forwarding wrapper aroundFSDataInputStream.FSDataOutputStream An output stream to a file that is created via aFileSystem.FSDataOutputStreamWrapper Simple forwarding wrapper aroundFSDataInputStream.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 AnOutputStreamthat keeps track of its current length.OutputStreamAndPath An output stream and a path.Path Names a file or directory in aFileSystem.PluginFileSystemFactory A wrapper aroundFileSystemFactorythat ensures the plugin classloader is used for allFileSystemoperations.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 recoversRecoverableFsDataOutputStream.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 ARefCountedFileWithStreamthat 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 wrappedFile.RefCountedFileWithStream A reference counted file which is deleted as soon as no caller holds a reference to the wrappedFile.RefCountedFSOutputStream AFSDataOutputStreamwith theRefCountedfunctionality.RefCountedTmpFileCreator A utility class that creates localreference counted filesthat serve as temporary files.SafetyNetCloseableRegistry This implementation of anAbstractAutoCloseableRegistryregistersWrappingProxyCloseable.WrappingProxyCloseable WrappingProxyforCloseablethat 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.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 aFileSystem.FSDataInputStream Interface for a data input stream to a file on aFileSystem.FSDataOutputStream An output stream to a file that is created via aFileSystem.LocatedFileStatus ALocatedFileStatusis aFileStatusthat contains additionally the location information of the file directly.Path Names a file or directory in aFileSystem.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 recoversRecoverableFsDataOutputStream.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 aFileSystem.