Package | Description |
---|---|
org.apache.hadoop.fs |
An abstract file system API.
|
org.apache.hadoop.fs.viewfs | |
org.apache.hadoop.hdfs |
A distributed implementation of
FileSystem . |
Modifier and Type | Method and Description |
---|---|
static Options.ChecksumOpt |
Options.ChecksumOpt.createDisabled()
Create a ChecksumOpts that disables checksum
|
Options.ChecksumOpt |
MD5MD5CRC32FileChecksum.getChecksumOpt() |
Options.ChecksumOpt |
Options.CreateOpts.ChecksumParam.getValue() |
static Options.ChecksumOpt |
Options.ChecksumOpt.processChecksumOpt(Options.ChecksumOpt defaultOpt,
Options.ChecksumOpt userOpt)
A helper method for processing user input and default value to
create a combined checksum option.
|
static Options.ChecksumOpt |
Options.ChecksumOpt.processChecksumOpt(Options.ChecksumOpt defaultOpt,
Options.ChecksumOpt userOpt,
int userBytesPerChecksum)
A helper method for processing user input and default value to
create a combined checksum option.
|
Modifier and Type | Method and Description |
---|---|
static Options.CreateOpts.ChecksumParam |
Options.CreateOpts.checksumParam(Options.ChecksumOpt csumOpt) |
FSDataOutputStream |
FileSystem.create(Path f,
FsPermission permission,
EnumSet<CreateFlag> flags,
int bufferSize,
short replication,
long blockSize,
Progressable progress,
Options.ChecksumOpt checksumOpt)
Create an FSDataOutputStream at the indicated Path with a custom
checksum option
|
HdfsDataOutputStream |
Hdfs.createInternal(Path f,
EnumSet<CreateFlag> createFlag,
FsPermission absolutePermission,
int bufferSize,
short replication,
long blockSize,
Progressable progress,
Options.ChecksumOpt checksumOpt,
boolean createParent) |
abstract FSDataOutputStream |
AbstractFileSystem.createInternal(Path f,
EnumSet<CreateFlag> flag,
FsPermission absolutePermission,
int bufferSize,
short replication,
long blockSize,
Progressable progress,
Options.ChecksumOpt checksumOpt,
boolean createParent)
The specification of this method matches that of
AbstractFileSystem.create(Path, EnumSet, Options.CreateOpts...) except that the opts
have been declared explicitly. |
FSDataOutputStream |
FilterFs.createInternal(Path f,
EnumSet<CreateFlag> flag,
FsPermission absolutePermission,
int bufferSize,
short replication,
long blockSize,
Progressable progress,
Options.ChecksumOpt checksumOpt,
boolean createParent) |
FSDataOutputStream |
DelegateToFileSystem.createInternal(Path f,
EnumSet<CreateFlag> flag,
FsPermission absolutePermission,
int bufferSize,
short replication,
long blockSize,
Progressable progress,
Options.ChecksumOpt checksumOpt,
boolean createParent) |
FSDataOutputStream |
ChecksumFs.createInternal(Path f,
EnumSet<CreateFlag> createFlag,
FsPermission absolutePermission,
int bufferSize,
short replication,
long blockSize,
Progressable progress,
Options.ChecksumOpt checksumOpt,
boolean createParent) |
protected FSDataOutputStream |
FilterFileSystem.primitiveCreate(Path f,
FsPermission absolutePermission,
EnumSet<CreateFlag> flag,
int bufferSize,
short replication,
long blockSize,
Progressable progress,
Options.ChecksumOpt checksumOpt) |
protected FSDataOutputStream |
FileSystem.primitiveCreate(Path f,
FsPermission absolutePermission,
EnumSet<CreateFlag> flag,
int bufferSize,
short replication,
long blockSize,
Progressable progress,
Options.ChecksumOpt checksumOpt)
Deprecated.
|
static Options.ChecksumOpt |
Options.ChecksumOpt.processChecksumOpt(Options.ChecksumOpt defaultOpt,
Options.ChecksumOpt userOpt)
A helper method for processing user input and default value to
create a combined checksum option.
|
static Options.ChecksumOpt |
Options.ChecksumOpt.processChecksumOpt(Options.ChecksumOpt defaultOpt,
Options.ChecksumOpt userOpt,
int userBytesPerChecksum)
A helper method for processing user input and default value to
create a combined checksum option.
|
Constructor and Description |
---|
Options.CreateOpts.ChecksumParam(Options.ChecksumOpt csumOpt) |
Modifier and Type | Method and Description |
---|---|
FSDataOutputStream |
ViewFs.createInternal(Path f,
EnumSet<CreateFlag> flag,
FsPermission absolutePermission,
int bufferSize,
short replication,
long blockSize,
Progressable progress,
Options.ChecksumOpt checksumOpt,
boolean createParent) |
Modifier and Type | Method and Description |
---|---|
FSDataOutputStream |
DistributedFileSystem.create(Path f,
FsPermission permission,
EnumSet<CreateFlag> cflags,
int bufferSize,
short replication,
long blockSize,
Progressable progress,
Options.ChecksumOpt checksumOpt) |
DFSOutputStream |
DFSClient.create(String src,
FsPermission permission,
EnumSet<CreateFlag> flag,
boolean createParent,
short replication,
long blockSize,
Progressable progress,
int buffersize,
Options.ChecksumOpt checksumOpt)
Create a new dfs file with the specified block replication
with write-progress reporting and return an output stream for writing
into the file.
|
DFSOutputStream |
DFSClient.create(String src,
FsPermission permission,
EnumSet<CreateFlag> flag,
boolean createParent,
short replication,
long blockSize,
Progressable progress,
int buffersize,
Options.ChecksumOpt checksumOpt,
InetSocketAddress[] favoredNodes)
Same as
#create(String, FsPermission, EnumSet, boolean, short, long,
Progressable, int, ChecksumOpt) with the addition of favoredNodes that is
a hint to where the namenode should place the file blocks. |
DFSOutputStream |
DFSClient.create(String src,
FsPermission permission,
EnumSet<CreateFlag> flag,
short replication,
long blockSize,
Progressable progress,
int buffersize,
Options.ChecksumOpt checksumOpt)
Call
#create(String, FsPermission, EnumSet, boolean, short,
long, Progressable, int, ChecksumOpt) with createParent
set to true. |
protected HdfsDataOutputStream |
DistributedFileSystem.primitiveCreate(Path f,
FsPermission absolutePermission,
EnumSet<CreateFlag> flag,
int bufferSize,
short replication,
long blockSize,
Progressable progress,
Options.ChecksumOpt checksumOpt) |
DFSOutputStream |
DFSClient.primitiveCreate(String src,
FsPermission absPermission,
EnumSet<CreateFlag> flag,
boolean createParent,
short replication,
long blockSize,
Progressable progress,
int buffersize,
Options.ChecksumOpt checksumOpt)
Same as {
#create(String, FsPermission, EnumSet, short, long,
Progressable, int, ChecksumOpt) except that the permission
is absolute (ie has already been masked with umask. |
Copyright © 2013 Apache Software Foundation. All rights reserved.