Interface | 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.
|
HadoopFileSystemWrapper | |
WrappingProxyCloseable<T extends Closeable> |
WrappingProxy for Closeable that is also closeable. |
Class | Description |
---|---|
AbstractMultiFSDataInputStream |
Abstract base class for wrappers over multiple
FSDataInputStream , which gives a contiguous view on all inner
streams and makes them look like a single stream, in which we can read, seek, etc. |
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. |
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.
|
FileSystem.FSKey |
An identifier of a file system, via its scheme and its authority.
|
FSDataInputStream |
Interface for a data input stream to a file on a
FileSystem . |
FSDataInputStreamWrapper |
Simple forwarding wrapper around
FSDataInputStream |
FSDataOutputStream |
Interface for a data output stream to a file on a
FileSystem . |
FSDataOutputStreamWrapper |
Simple forwarding wrapper around
FSDataInputStream |
Path |
Names a file or directory in a
FileSystem . |
SafetyNetCloseableRegistry |
This implementation of an
AbstractCloseableRegistry 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 | Description |
---|---|
FileSystem.WriteMode |
The possible write modes.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.