| 程序包 | 说明 |
|---|---|
| org.apache.hadoop.fs |
An abstract file system API.
|
| org.apache.hadoop.fs.ftp | |
| org.apache.hadoop.fs.kfs |
A client for the Kosmos filesystem (KFS)
Introduction
This pages describes how to use Kosmos Filesystem
( KFS ) as a backing
store with Hadoop.
|
| org.apache.hadoop.fs.s3 |
A distributed, block-based implementation of
FileSystem that uses Amazon S3
as a backing store. |
| org.apache.hadoop.fs.s3native |
A distributed implementation of
FileSystem for reading and writing files on
Amazon S3. |
| org.apache.hadoop.hdfs |
A distributed implementation of
FileSystem. |
| org.apache.hadoop.hdfs.web | |
| 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.streaming |
Hadoop Streaming is a utility which allows users to create and run
Map-Reduce jobs with any executables (e.g.
|
| 限定符和类型 | 方法和说明 |
|---|---|
FSDataInputStream |
FileSystem.open(Path f)
Opens an FSDataInputStream at the indicated Path.
|
FSDataInputStream |
RawLocalFileSystem.open(Path f,
int bufferSize) |
FSDataInputStream |
HarFileSystem.open(Path f,
int bufferSize)
Returns a har input stream which fakes end of
file.
|
FSDataInputStream |
FilterFileSystem.open(Path f,
int bufferSize)
Opens an FSDataInputStream at the indicated Path.
|
abstract FSDataInputStream |
FileSystem.open(Path f,
int bufferSize)
Opens an FSDataInputStream at the indicated Path.
|
FSDataInputStream |
ChecksumFileSystem.open(Path f,
int bufferSize)
Opens an FSDataInputStream at the indicated Path.
|
| 限定符和类型 | 方法和说明 |
|---|---|
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.
|
boolean |
ChecksumFileSystem.reportChecksumFailure(Path f,
FSDataInputStream in,
long inPos,
FSDataInputStream sums,
long sumsPos)
Report a checksum error to the file system.
|
| 限定符和类型 | 方法和说明 |
|---|---|
FSDataInputStream |
FTPFileSystem.open(Path file,
int bufferSize) |
| 限定符和类型 | 方法和说明 |
|---|---|
FSDataInputStream |
KosmosFileSystem.open(Path path,
int bufferSize) |
| 限定符和类型 | 方法和说明 |
|---|---|
FSDataInputStream |
S3FileSystem.open(Path path,
int bufferSize) |
| 限定符和类型 | 方法和说明 |
|---|---|
FSDataInputStream |
NativeS3FileSystem.open(Path f,
int bufferSize) |
| 限定符和类型 | 类和说明 |
|---|---|
static class |
DFSClient.DFSDataInputStream
The Hdfs implementation of
FSDataInputStream |
| 限定符和类型 | 方法和说明 |
|---|---|
FSDataInputStream |
HftpFileSystem.open(Path f,
int buffersize) |
FSDataInputStream |
DistributedFileSystem.open(Path f,
int bufferSize) |
| 限定符和类型 | 方法和说明 |
|---|---|
boolean |
DistributedFileSystem.reportChecksumFailure(Path f,
FSDataInputStream in,
long inPos,
FSDataInputStream sums,
long sumsPos)
We need to find the blocks that didn't match.
|
boolean |
ChecksumDistributedFileSystem.reportChecksumFailure(Path f,
FSDataInputStream in,
long inPos,
FSDataInputStream sums,
long sumsPos)
We need to find the blocks that didn't match.
|
| 限定符和类型 | 方法和说明 |
|---|---|
FSDataInputStream |
WebHdfsFileSystem.open(Path f,
int buffersize) |
| 限定符和类型 | 方法和说明 |
|---|---|
protected FSDataInputStream |
SequenceFile.Reader.openFile(FileSystem fs,
Path file,
int bufferSize,
long length)
Override this method to specialize the type of
FSDataInputStream returned. |
| 构造器和说明 |
|---|
TFile.Reader(FSDataInputStream fsdis,
long fileLength,
Configuration conf)
Constructor
|
| 构造器和说明 |
|---|
StreamBaseRecordReader(FSDataInputStream in,
FileSplit split,
Reporter reporter,
JobConf job,
FileSystem fs) |
StreamXmlRecordReader(FSDataInputStream in,
FileSplit split,
Reporter reporter,
JobConf job,
FileSystem fs) |
Copyright © 2009 The Apache Software Foundation