| Package | Description |
|---|---|
| org.apache.hadoop.fs |
An abstract file system API.
|
| org.apache.hadoop.fs.crypto | |
| org.apache.hadoop.fs.ftp | |
| org.apache.hadoop.fs.sftp |
SFTP FileSystem package.
|
| org.apache.hadoop.fs.viewfs | |
| org.apache.hadoop.io |
Generic i/o code for use when reading and writing data to the network,
to databases, and to files.
|
| org.apache.hadoop.io.file.tfile | |
| org.apache.hadoop.util |
Common utilities.
|
| Modifier and Type | Method and Description |
|---|---|
FSDataInputStream |
AbstractFileSystem.open(Path f)
The specification of this method matches that of
FileContext.open(Path) except that Path f must be for this
file system. |
FSDataInputStream |
FileContext.open(Path f)
Opens an FSDataInputStream at the indicated Path using
default buffersize.
|
FSDataInputStream |
FileSystem.open(Path f)
Opens an FSDataInputStream at the indicated Path.
|
FSDataInputStream |
ChecksumFileSystem.open(Path f,
int bufferSize)
Opens an FSDataInputStream at the indicated Path.
|
abstract FSDataInputStream |
AbstractFileSystem.open(Path f,
int bufferSize)
The specification of this method matches that of
FileContext.open(Path, int) except that Path f must be for this
file system. |
FSDataInputStream |
FileContext.open(Path f,
int bufferSize)
Opens an FSDataInputStream at the indicated Path.
|
FSDataInputStream |
FilterFileSystem.open(Path f,
int bufferSize)
Opens an FSDataInputStream at the indicated Path.
|
FSDataInputStream |
HarFileSystem.open(Path f,
int bufferSize)
Returns a har input stream which fakes end of
file.
|
abstract FSDataInputStream |
FileSystem.open(Path f,
int bufferSize)
Opens an FSDataInputStream at the indicated Path.
|
FSDataInputStream |
RawLocalFileSystem.open(Path f,
int bufferSize) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
ChecksumFileSystem.reportChecksumFailure(Path f,
FSDataInputStream in,
long inPos,
FSDataInputStream sums,
long sumsPos)
Report a checksum error to the file system.
|
boolean |
LocalFileSystem.reportChecksumFailure(Path p,
FSDataInputStream in,
long inPos,
FSDataInputStream sums,
long sumsPos)
Moves files to a bad file directory on the same device, so that their
storage will not be reused.
|
| Constructor and Description |
|---|
AvroFSInput(FSDataInputStream in,
long len)
Construct given an
FSDataInputStream and its length. |
| Modifier and Type | Class and Description |
|---|---|
class |
CryptoFSDataInputStream |
| Constructor and Description |
|---|
CryptoFSDataInputStream(FSDataInputStream in,
org.apache.hadoop.crypto.CryptoCodec codec,
byte[] key,
byte[] iv) |
CryptoFSDataInputStream(FSDataInputStream in,
org.apache.hadoop.crypto.CryptoCodec codec,
int bufferSize,
byte[] key,
byte[] iv) |
| Modifier and Type | Method and Description |
|---|---|
FSDataInputStream |
FTPFileSystem.open(Path file,
int bufferSize) |
| Modifier and Type | Method and Description |
|---|---|
FSDataInputStream |
SFTPFileSystem.open(Path f,
int bufferSize) |
| Modifier and Type | Method and Description |
|---|---|
FSDataInputStream |
ViewFs.open(Path f,
int bufferSize) |
FSDataInputStream |
ViewFileSystem.open(Path f,
int bufferSize) |
| Modifier and Type | Method and Description |
|---|---|
protected static FSDataInputStream |
SecureIOUtils.forceSecureOpenFSDataInputStream(File file,
String expectedOwner,
String expectedGroup)
Same as openFSDataInputStream except that it will run even if security is
off.
|
protected FSDataInputStream |
SequenceFile.Reader.openFile(FileSystem fs,
Path file,
int bufferSize,
long length)
Override this method to specialize the type of
FSDataInputStream returned. |
static FSDataInputStream |
SecureIOUtils.openFSDataInputStream(File file,
String expectedOwner,
String expectedGroup)
Opens the
FSDataInputStream on the requested file on local file
system, verifying the expected user/group constraints if security is
enabled. |
| Modifier and Type | Method and Description |
|---|---|
static SequenceFile.Reader.Option |
SequenceFile.Reader.stream(FSDataInputStream value)
Create an option to specify the stream with the sequence file.
|
| Constructor and Description |
|---|
SequenceFile.Reader(FSDataInputStream in,
int buffersize,
long start,
long length,
Configuration conf)
Deprecated.
Use Reader(Configuration, Reader.Option...) instead.
|
| Constructor and Description |
|---|
BoundedRangeFileInputStream(FSDataInputStream in,
long offset,
long length)
Constructor
|
TFile.Reader(FSDataInputStream fsdis,
long fileLength,
Configuration conf)
Constructor
|
| Modifier and Type | Method and Description |
|---|---|
FSDataInputStream |
Options.FSDataInputStreamOption.getValue() |
| Constructor and Description |
|---|
Options.FSDataInputStreamOption(FSDataInputStream value) |
Copyright © 2018 Apache Software Foundation. All Rights Reserved.