Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and 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 . |
Class and Description |
---|
FSDataOutputStream
An output stream to a file that is created via a
FileSystem . |
Class and Description |
---|
FileSystem.WriteMode
The possible write modes.
|
Class and 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.
|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
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.
|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
FSDataInputStream
Interface for a data input stream to a file on a
FileSystem . |
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
FileSystem
Abstract base class of all file systems used by Flink.
|
Path
Names a file or directory in a
FileSystem . |
Class and 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.
|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
CloseableRegistry
This class allows to register instances of
Closeable , which are all closed if this
registry is closed. |
Class and Description |
---|
CloseableRegistry
This class allows to register instances of
Closeable , which are all closed if this
registry is closed. |
Class and Description |
---|
CloseableRegistry
This class allows to register instances of
Closeable , which are all closed if this
registry is closed. |
Class and Description |
---|
CloseableRegistry
This class allows to register instances of
Closeable , which are all closed if this
registry is closed. |
Class and Description |
---|
BlockLocation
A BlockLocation lists hosts, offset and length of block.
|
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 . |
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.
|
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.
|
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.
|
SafetyNetCloseableRegistry
This implementation of an
AbstractCloseableRegistry registers WrappingProxyCloseable . |
WrappingProxyCloseable
WrappingProxy for Closeable that is also closeable. |
Class and 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 a
FileSystem . |
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 . |
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.
|
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and 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.
|
FSDataOutputStream
An output stream to a file that is created via a
FileSystem . |
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
FSDataOutputStream
An output stream to a file that is created via a
FileSystem . |
Class and Description |
---|
FSDataOutputStream
An output stream to a file that is created via a
FileSystem . |
Class and 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.
|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
FSDataOutputStream
An output stream to a file that is created via a
FileSystem . |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
FSDataOutputStream
An output stream to a file that is created via a
FileSystem . |
Class and Description |
---|
FileSystem
Abstract base class of all file systems used by Flink.
|
FileSystemFactory
A factory to create file systems.
|
Class and Description |
---|
FileSystem
Abstract base class of all file systems used by Flink.
|
FileSystemFactory
A factory to create file systems.
|
Class and Description |
---|
FileSystem
Abstract base class of all file systems used by Flink.
|
FileSystemFactory
A factory to create file systems.
|
Class and Description |
---|
FileSystem
Abstract base class of all file systems used by Flink.
|
FileSystemFactory
A factory to create file systems.
|
Class and Description |
---|
EntropyInjectingFileSystem
An interface to be implemented by a
FileSystem that is aware of entropy injection. |
FileSystem
Abstract base class of all file systems used by Flink.
|
FileSystemFactory
A factory to create file systems.
|
FileSystemKind
An enumeration defining the kind and characteristics of a
FileSystem . |
RecoverableWriter
The RecoverableWriter creates and recovers
RecoverableFsDataOutputStream . |
Class and Description |
---|
FSDataOutputStream
An output stream to a file that is created via a
FileSystem . |
RefCountedFile
A reference counted file which is deleted as soon as no caller holds a reference to the wrapped
File . |
Class and Description |
---|
FSDataOutputStream
An output stream to a file that is created via a
FileSystem . |
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.
|
Class and Description |
---|
FileSystemFactory
A factory to create file systems.
|
Class and Description |
---|
FileSystemFactory
A factory to create file systems.
|
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
FSDataOutputStream
An output stream to a file that is created via a
FileSystem . |
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
FSDataOutputStream
An output stream to a file that is created via a
FileSystem . |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
FSDataOutputStream
An output stream to a file that is created via a
FileSystem . |
Class and Description |
---|
FileSystem
Abstract base class of all file systems used by Flink.
|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and 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 a
FileSystem . |
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 . |
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.
|
Class and Description |
---|
FileSystem
Abstract base class of all file systems used by Flink.
|
FileSystemFactory
A factory to create file systems.
|
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
RefCountedFile
A reference counted file which is deleted as soon as no caller holds a reference to the wrapped
File . |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
CloseableRegistry
This class allows to register instances of
Closeable , which are all closed if this
registry is closed. |
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 . |
Class and Description |
---|
CloseableRegistry
This class allows to register instances of
Closeable , which are all closed if this
registry is closed. |
FileSystem
Abstract base class of all file systems used by Flink.
|
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 . |
Class and Description |
---|
CloseableRegistry
This class allows to register instances of
Closeable , which are all closed if this
registry is closed. |
Class and Description |
---|
CloseableRegistry
This class allows to register instances of
Closeable , which are all closed if this
registry is closed. |
Class and Description |
---|
CloseableRegistry
This class allows to register instances of
Closeable , which are all closed if this
registry is closed. |
FileSystem
Abstract base class of all file systems used by Flink.
|
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 . |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
CloseableRegistry
This class allows to register instances of
Closeable , which are all closed if this
registry is closed. |
Class and Description |
---|
FileSystem.WriteMode
The possible write modes.
|
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
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.
|
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.
|
Class and 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.
|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
CloseableRegistry
This class allows to register instances of
Closeable , which are all closed if this
registry is closed. |
Class and Description |
---|
CloseableRegistry
This class allows to register instances of
Closeable , which are all closed if this
registry is closed. |
Class and Description |
---|
CloseableRegistry
This class allows to register instances of
Closeable , which are all closed if this
registry is closed. |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
FileSystem
Abstract base class of all file systems used by Flink.
|
FSDataOutputStream
An output stream to a file that is created via a
FileSystem . |
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
FileSystem
Abstract base class of all file systems used by Flink.
|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
FileSystem.WriteMode
The possible write modes.
|
Class and Description |
---|
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.
|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
Path
Names a file or directory in a
FileSystem . |
Class and Description |
---|
FileSystem
Abstract base class of all file systems used by Flink.
|
Path
Names a file or directory in a
FileSystem . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.