Package | Description |
---|---|
org.apache.hadoop.fs |
Implementations of
AbstractFileSystem for hdfs
over rpc and hdfs over web. |
org.apache.hadoop.fs.adl |
Supporting classes for metrics instrumentation.
|
org.apache.hadoop.fs.azure |
A distributed implementation of
FileSystem for reading and writing files on
Azure Block Storage. |
org.apache.hadoop.fs.ftp | |
org.apache.hadoop.fs.s3native |
A distributed implementation of
FileSystem for reading and writing files on
Amazon S3. |
org.apache.hadoop.fs.viewfs | |
org.apache.hadoop.hdfs.client |
This package provides the administrative APIs for HDFS.
|
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 |
FileSystem.open(PathHandle fd)
Open an FSDataInputStream matching the PathHandle instance.
|
FSDataInputStream |
RawLocalFileSystem.open(PathHandle fd,
int bufferSize) |
FSDataInputStream |
FilterFileSystem.open(PathHandle fd,
int bufferSize) |
FSDataInputStream |
FileSystem.open(PathHandle fd,
int bufferSize)
Open an FSDataInputStream matching the PathHandle instance.
|
FSDataInputStream |
RawLocalFileSystem.open(Path f,
int bufferSize) |
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 |
ChecksumFileSystem.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.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<FSDataInputStream> |
FutureDataInputStreamBuilder.build() |
protected CompletableFuture<FSDataInputStream> |
FilterFileSystem.openFileWithOptions(PathHandle pathHandle,
Set<String> mandatoryKeys,
Configuration options,
int bufferSize) |
protected CompletableFuture<FSDataInputStream> |
FileSystem.openFileWithOptions(PathHandle pathHandle,
Set<String> mandatoryKeys,
Configuration options,
int bufferSize)
Execute the actual open file operation.
|
CompletableFuture<FSDataInputStream> |
AbstractFileSystem.openFileWithOptions(Path path,
Set<String> mandatoryKeys,
Configuration options,
int bufferSize)
Open a file with the given set of options.
|
protected CompletableFuture<FSDataInputStream> |
FilterFileSystem.openFileWithOptions(Path path,
Set<String> mandatoryKeys,
Configuration options,
int bufferSize) |
protected CompletableFuture<FSDataInputStream> |
ChecksumFileSystem.openFileWithOptions(Path path,
Set<String> mandatoryKeys,
Configuration options,
int bufferSize)
Open the file as a blocking call to
ChecksumFileSystem.open(Path, int) . |
protected CompletableFuture<FSDataInputStream> |
FileSystem.openFileWithOptions(Path path,
Set<String> mandatoryKeys,
Configuration options,
int bufferSize)
Execute the actual open file operation.
|
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 | Method and Description |
---|---|
FSDataInputStream |
AdlFileSystem.open(Path f,
int buffersize)
Open call semantic is handled differently in case of ADL.
|
Modifier and Type | Method and Description |
---|---|
FSDataInputStream |
NativeAzureFileSystem.open(Path f,
int bufferSize) |
Modifier and Type | Method and Description |
---|---|
FSDataInputStream |
FTPFileSystem.open(Path file,
int bufferSize) |
Modifier and Type | Method and Description |
---|---|
FSDataInputStream |
NativeS3FileSystem.open(Path f,
int bufferSize)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
FSDataInputStream |
ViewFileSystem.open(Path f,
int bufferSize) |
FSDataInputStream |
ViewFs.open(Path f,
int bufferSize) |
Modifier and Type | Class and Description |
---|---|
class |
HdfsDataInputStream
The Hdfs implementation of
FSDataInputStream . |
Copyright © 2019 Apache Software Foundation. All rights reserved.