Package | Description |
---|---|
org.apache.hadoop.conf |
Configuration of system parameters.
|
org.apache.hadoop.fs |
An abstract file system API.
|
org.apache.hadoop.fs.ftp | |
org.apache.hadoop.fs.sftp |
SFTP FileSystem package.
|
org.apache.hadoop.fs.shell.find | |
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.compress | |
org.apache.hadoop.security | |
org.apache.hadoop.util |
Common utilities.
|
Modifier and Type | Method and Description |
---|---|
Path |
Configuration.getLocalPath(String dirsProp,
String path)
Get a local file under a directory named by dirsProp with
the given path.
|
Modifier and Type | Method and Description |
---|---|
void |
Configuration.addResource(Path file)
Add a configuration resource.
|
Modifier and Type | Field and Description |
---|---|
protected Path |
TrashPolicy.trash |
Modifier and Type | Method and Description |
---|---|
Path |
FileSystem.createSnapshot(Path path)
Create a snapshot with a default name.
|
Path |
FileContext.createSnapshot(Path path)
Create a snapshot with a default name.
|
Path |
FilterFileSystem.createSnapshot(Path path,
String snapshotName) |
Path |
FileSystem.createSnapshot(Path path,
String snapshotName)
Create a snapshot
|
Path |
FileContext.createSnapshot(Path path,
String snapshotName)
Create a snapshot.
|
Path |
AbstractFileSystem.createSnapshot(Path path,
String snapshotName)
The specification of this method matches that of
FileContext.createSnapshot(Path, String) . |
protected Path |
FileSystem.fixRelativePart(Path p)
|
Path |
ChecksumFileSystem.getChecksumFile(Path file)
Return the name of the checksum file associated with a file.
|
abstract Path |
TrashPolicy.getCurrentTrashDir()
Get the current working directory of the Trash Policy
This API does not work with files deleted from encryption zone when HDFS
data encryption at rest feature is enabled as rename file between
encryption zones or encryption zone and non-encryption zone is not allowed.
|
Path |
TrashPolicy.getCurrentTrashDir(Path path)
Get the current trash directory for path specified based on the Trash
Policy
|
Path |
Trash.getCurrentTrashDir(Path path) |
Path |
RawLocalFileSystem.getHomeDirectory() |
Path |
HarFileSystem.getHomeDirectory()
return the top level archive path.
|
Path |
FilterFileSystem.getHomeDirectory() |
Path |
FileSystem.getHomeDirectory()
Return the current user's home directory in this filesystem.
|
Path |
FileContext.getHomeDirectory()
Return the current user's home directory in this file system.
|
Path |
AbstractFileSystem.getHomeDirectory()
Return the current user's home directory in this file system.
|
protected Path |
RawLocalFileSystem.getInitialWorkingDirectory() |
Path |
HarFileSystem.getInitialWorkingDirectory() |
protected Path |
FilterFileSystem.getInitialWorkingDirectory() |
protected Path |
FileSystem.getInitialWorkingDirectory()
Note: with the new FilesContext class, getWorkingDirectory()
will be removed.
|
Path |
AbstractFileSystem.getInitialWorkingDirectory()
Some file systems like LocalFileSystem have an initial workingDir
that is used as the starting workingDir.
|
Path |
RawLocalFileSystem.getLinkTarget(Path f) |
Path |
LocalFileSystem.getLinkTarget(Path f) |
Path |
FilterFileSystem.getLinkTarget(Path f) |
Path |
FileSystem.getLinkTarget(Path f)
|
Path |
FileContext.getLinkTarget(Path f)
Returns the target of the given symbolic link as it was specified
when the link was created.
|
Path |
AbstractFileSystem.getLinkTarget(Path f)
Partially resolves the path.
|
Path |
Path.getParent()
Returns the parent of a path or null if at root.
|
Path |
PathIOException.getPath() |
Path |
FileStatus.getPath() |
static Path |
Path.getPathWithoutSchemeAndAuthority(Path path)
Return a version of the given Path without the scheme information.
|
Path |
FileStatus.getSymlink() |
Path |
PathIOException.getTargetPath() |
Path |
FilterFileSystem.getTrashRoot(Path path) |
Path |
FileSystem.getTrashRoot(Path path)
Get the root directory of Trash for current user when the path specified
is deleted.
|
Path |
RawLocalFileSystem.getWorkingDirectory() |
Path |
HarFileSystem.getWorkingDirectory()
return the top level archive.
|
Path |
FilterFileSystem.getWorkingDirectory()
Get the current working directory for the given file system
|
abstract Path |
FileSystem.getWorkingDirectory()
Get the current working directory for the given file system
|
Path |
FileContext.getWorkingDirectory()
Gets the working directory for wd-relative names (such a "foo/bar").
|
Path |
Path.makeQualified(FileSystem fs)
Deprecated.
|
Path |
HarFileSystem.makeQualified(Path path) |
Path |
FilterFileSystem.makeQualified(Path path)
Make sure that a path specifies a FileSystem.
|
Path |
FileSystem.makeQualified(Path path)
Make sure that a path specifies a FileSystem.
|
Path |
FileContext.makeQualified(Path path)
Make the path fully qualified if it is isn't.
|
Path |
AbstractFileSystem.makeQualified(Path path)
Make the path fully qualified to this file system
|
static Path |
Path.mergePaths(Path path1,
Path path2)
Merge 2 paths such that the second path is appended relative to the first.
|
protected Path |
FileContext.resolve(Path f)
Resolves all symbolic links in the specified path.
|
protected Path |
FileContext.resolveIntermediate(Path f)
Resolves all symbolic links in the specified path leading up
to, but not including the final path component.
|
protected Path |
FilterFileSystem.resolveLink(Path f) |
protected Path |
FileSystem.resolveLink(Path f)
|
Path |
HarFileSystem.resolvePath(Path p) |
Path |
FilterFileSystem.resolvePath(Path p) |
Path |
FileSystem.resolvePath(Path p)
Return the fully-qualified path of path f resolving the path
through any symlinks or mount point
|
Path |
FileContext.resolvePath(Path f)
Resolve the path following any symlinks or mount points
|
Path |
AbstractFileSystem.resolvePath(Path p)
Return the fully-qualified path of path f resolving the path
through any internal symlinks or mount point
|
Path |
RawLocalFileSystem.startLocalOutput(Path fsOutputFile,
Path tmpLocalFile) |
Path |
HarFileSystem.startLocalOutput(Path fsOutputFile,
Path tmpLocalFile)
not implemented.
|
Path |
FilterFileSystem.startLocalOutput(Path fsOutputFile,
Path tmpLocalFile)
Returns a local File that the user can write output to.
|
Path |
FileSystem.startLocalOutput(Path fsOutputFile,
Path tmpLocalFile)
Returns a local File that the user can write output to.
|
Path |
ChecksumFileSystem.startLocalOutput(Path fsOutputFile,
Path tmpLocalFile) |
static Path[] |
FileUtil.stat2Paths(FileStatus[] stats)
convert an array of FileStatus to an array of Path
|
static Path[] |
FileUtil.stat2Paths(FileStatus[] stats,
Path path)
convert an array of FileStatus to an array of Path.
|
Path |
Path.suffix(String suffix)
Adds a suffix to the final name in the path.
|
Modifier and Type | Method and Description |
---|---|
RemoteIterator<Path> |
FilterFileSystem.listCorruptFileBlocks(Path path) |
RemoteIterator<Path> |
FileSystem.listCorruptFileBlocks(Path path) |
RemoteIterator<Path> |
FileContext.listCorruptFileBlocks(Path path) |
RemoteIterator<Path> |
AbstractFileSystem.listCorruptFileBlocks(Path path) |
Modifier and Type | Method and Description |
---|---|
boolean |
PathFilter.accept(Path path)
Tests whether or not the specified abstract pathname should be
included in a pathname list.
|
boolean |
GlobFilter.accept(Path path) |
void |
FilterFileSystem.access(Path path,
FsAction mode) |
FSDataOutputStream |
HarFileSystem.append(Path f) |
FSDataOutputStream |
FileSystem.append(Path f)
Append to an existing file (optional operation).
|
FSDataOutputStream |
FileSystem.append(Path f,
int bufferSize)
Append to an existing file (optional operation).
|
FSDataOutputStream |
RawLocalFileSystem.append(Path f,
int bufferSize,
Progressable progress) |
FSDataOutputStream |
HarFileSystem.append(Path f,
int bufferSize,
Progressable progress) |
FSDataOutputStream |
FilterFileSystem.append(Path f,
int bufferSize,
Progressable progress) |
abstract FSDataOutputStream |
FileSystem.append(Path f,
int bufferSize,
Progressable progress)
Append to an existing file (optional operation).
|
FSDataOutputStream |
ChecksumFileSystem.append(Path f,
int bufferSize,
Progressable progress) |
boolean |
FileSystem.cancelDeleteOnExit(Path f)
Cancel the deletion of the path when the FileSystem is closed
|
protected void |
HarFileSystem.checkPath(Path path) |
protected void |
FilterFileSystem.checkPath(Path path)
Check that a Path belongs to this FileSystem.
|
protected void |
FileSystem.checkPath(Path path)
Check that a Path belongs to this FileSystem.
|
void |
AbstractFileSystem.checkPath(Path path)
Check that a Path belongs to this FileSystem.
|
void |
RawLocalFileSystem.completeLocalOutput(Path fsWorkingFile,
Path tmpLocalFile) |
void |
HarFileSystem.completeLocalOutput(Path fsOutputFile,
Path tmpLocalFile)
not implemented.
|
void |
FilterFileSystem.completeLocalOutput(Path fsOutputFile,
Path tmpLocalFile)
Called when we're all done writing to the target.
|
void |
FileSystem.completeLocalOutput(Path fsOutputFile,
Path tmpLocalFile)
Called when we're all done writing to the target.
|
void |
ChecksumFileSystem.completeLocalOutput(Path fsOutputFile,
Path tmpLocalFile) |
void |
FilterFileSystem.concat(Path f,
Path[] psrcs) |
void |
FilterFileSystem.concat(Path f,
Path[] psrcs) |
void |
FileSystem.concat(Path trg,
Path[] psrcs)
Concat existing files together.
|
void |
FileSystem.concat(Path trg,
Path[] psrcs)
Concat existing files together.
|
static boolean |
FileUtil.copy(File src,
FileSystem dstFS,
Path dst,
boolean deleteSource,
Configuration conf)
Copy local files to a FileSystem.
|
static boolean |
FileUtil.copy(FileSystem srcFS,
FileStatus srcStatus,
FileSystem dstFS,
Path dst,
boolean deleteSource,
boolean overwrite,
Configuration conf)
Copy files between FileSystems.
|
static boolean |
FileUtil.copy(FileSystem srcFS,
Path[] srcs,
FileSystem dstFS,
Path dst,
boolean deleteSource,
boolean overwrite,
Configuration conf) |
static boolean |
FileUtil.copy(FileSystem srcFS,
Path[] srcs,
FileSystem dstFS,
Path dst,
boolean deleteSource,
boolean overwrite,
Configuration conf) |
static boolean |
FileUtil.copy(FileSystem srcFS,
Path src,
File dst,
boolean deleteSource,
Configuration conf)
Copy FileSystem files to local files.
|
static boolean |
FileUtil.copy(FileSystem srcFS,
Path src,
FileSystem dstFS,
Path dst,
boolean deleteSource,
boolean overwrite,
Configuration conf)
Copy files between FileSystems.
|
static boolean |
FileUtil.copy(FileSystem srcFS,
Path src,
FileSystem dstFS,
Path dst,
boolean deleteSource,
Configuration conf)
Copy files between FileSystems.
|
boolean |
FileContext.Util.copy(Path src,
Path dst)
Copy file from src to dest.
|
boolean |
FileContext.Util.copy(Path src,
Path dst,
boolean deleteSource,
boolean overwrite)
Copy from src to dst, optionally deleting src and overwriting dst.
|
void |
HarFileSystem.copyFromLocalFile(boolean delSrc,
boolean overwrite,
Path[] srcs,
Path dst) |
void |
HarFileSystem.copyFromLocalFile(boolean delSrc,
boolean overwrite,
Path[] srcs,
Path dst) |
void |
FilterFileSystem.copyFromLocalFile(boolean delSrc,
boolean overwrite,
Path[] srcs,
Path dst)
The src files are on the local disk.
|
void |
FilterFileSystem.copyFromLocalFile(boolean delSrc,
boolean overwrite,
Path[] srcs,
Path dst)
The src files are on the local disk.
|
void |
FileSystem.copyFromLocalFile(boolean delSrc,
boolean overwrite,
Path[] srcs,
Path dst)
The src files are on the local disk.
|
void |
FileSystem.copyFromLocalFile(boolean delSrc,
boolean overwrite,
Path[] srcs,
Path dst)
The src files are on the local disk.
|
void |
HarFileSystem.copyFromLocalFile(boolean delSrc,
boolean overwrite,
Path src,
Path dst)
not implemented.
|
void |
FilterFileSystem.copyFromLocalFile(boolean delSrc,
boolean overwrite,
Path src,
Path dst)
The src file is on the local disk.
|
void |
FileSystem.copyFromLocalFile(boolean delSrc,
boolean overwrite,
Path src,
Path dst)
The src file is on the local disk.
|
void |
LocalFileSystem.copyFromLocalFile(boolean delSrc,
Path src,
Path dst) |
void |
FilterFileSystem.copyFromLocalFile(boolean delSrc,
Path src,
Path dst)
The src file is on the local disk.
|
void |
FileSystem.copyFromLocalFile(boolean delSrc,
Path src,
Path dst)
The src file is on the local disk.
|
void |
ChecksumFileSystem.copyFromLocalFile(boolean delSrc,
Path src,
Path dst) |
void |
FileSystem.copyFromLocalFile(Path src,
Path dst)
The src file is on the local disk.
|
static boolean |
FileUtil.copyMerge(FileSystem srcFS,
Path srcDir,
FileSystem dstFS,
Path dstFile,
boolean deleteSource,
Configuration conf,
String addString)
Deprecated.
|
void |
LocalFileSystem.copyToLocalFile(boolean delSrc,
Path src,
Path dst) |
void |
HarFileSystem.copyToLocalFile(boolean delSrc,
Path src,
Path dst)
copies the file in the har filesystem to a local file.
|
void |
FilterFileSystem.copyToLocalFile(boolean delSrc,
Path src,
Path dst)
The src file is under FS, and the dst is on the local disk.
|
void |
FileSystem.copyToLocalFile(boolean delSrc,
Path src,
Path dst)
The src file is under FS, and the dst is on the local disk.
|
void |
ChecksumFileSystem.copyToLocalFile(boolean delSrc,
Path src,
Path dst)
The src file is under FS, and the dst is on the local disk.
|
void |
FileSystem.copyToLocalFile(boolean delSrc,
Path src,
Path dst,
boolean useRawLocalFileSystem)
The src file is under FS, and the dst is on the local disk.
|
void |
FileSystem.copyToLocalFile(Path src,
Path dst)
The src file is under FS, and the dst is on the local disk.
|
void |
ChecksumFileSystem.copyToLocalFile(Path src,
Path dst,
boolean copyCrc)
The src file is under FS, and the dst is on the local disk.
|
static FSDataOutputStream |
FileSystem.create(FileSystem fs,
Path file,
FsPermission permission)
create a file with the provided permission
The permission of the file is set to be the provided permission as in
setPermission, not permission&~umask
It is implemented using two RPCs.
|
FSDataOutputStream |
FileSystem.create(Path f)
Create an FSDataOutputStream at the indicated Path.
|
FSDataOutputStream |
FileSystem.create(Path f,
boolean overwrite)
Create an FSDataOutputStream at the indicated Path.
|
FSDataOutputStream |
FileSystem.create(Path f,
boolean overwrite,
int bufferSize)
Create an FSDataOutputStream at the indicated Path.
|
FSDataOutputStream |
FileSystem.create(Path f,
boolean overwrite,
int bufferSize,
Progressable progress)
Create an FSDataOutputStream at the indicated Path with write-progress
reporting.
|
FSDataOutputStream |
FileSystem.create(Path f,
boolean overwrite,
int bufferSize,
short replication,
long blockSize)
Create an FSDataOutputStream at the indicated Path.
|
FSDataOutputStream |
RawLocalFileSystem.create(Path f,
boolean overwrite,
int bufferSize,
short replication,
long blockSize,
Progressable progress) |
FSDataOutputStream |
FileSystem.create(Path f,
boolean overwrite,
int bufferSize,
short replication,
long blockSize,
Progressable progress)
Create an FSDataOutputStream at the indicated Path with write-progress
reporting.
|
FSDataOutputStream |
FileContext.create(Path f,
EnumSet<CreateFlag> createFlag,
Options.CreateOpts... opts)
Create or overwrite file on indicated path and returns an output stream for
writing into the file.
|
FSDataOutputStream |
AbstractFileSystem.create(Path f,
EnumSet<CreateFlag> createFlag,
Options.CreateOpts... opts)
The specification of this method matches that of
FileContext.create(Path, EnumSet, Options.CreateOpts...) except
that the Path f must be fully qualified and the permission is absolute
(i.e. |
FSDataOutputStream |
RawLocalFileSystem.create(Path f,
FsPermission permission,
boolean overwrite,
int bufferSize,
short replication,
long blockSize,
Progressable progress) |
FSDataOutputStream |
HarFileSystem.create(Path f,
FsPermission permission,
boolean overwrite,
int bufferSize,
short replication,
long blockSize,
Progressable progress) |
FSDataOutputStream |
FilterFileSystem.create(Path f,
FsPermission permission,
boolean overwrite,
int bufferSize,
short replication,
long blockSize,
Progressable progress) |
abstract FSDataOutputStream |
FileSystem.create(Path f,
FsPermission permission,
boolean overwrite,
int bufferSize,
short replication,
long blockSize,
Progressable progress)
Create an FSDataOutputStream at the indicated Path with write-progress
reporting.
|
FSDataOutputStream |
ChecksumFileSystem.create(Path f,
FsPermission permission,
boolean overwrite,
int bufferSize,
short replication,
long blockSize,
Progressable progress) |
FSDataOutputStream |
FileSystem.create(Path f,
FsPermission permission,
EnumSet<CreateFlag> flags,
int bufferSize,
short replication,
long blockSize,
Progressable progress)
Create an FSDataOutputStream at the indicated Path with write-progress
reporting.
|
FSDataOutputStream |
FilterFileSystem.create(Path f,
FsPermission permission,
EnumSet<CreateFlag> flags,
int bufferSize,
short replication,
long blockSize,
Progressable progress,
Options.ChecksumOpt checksumOpt) |
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
|
FSDataOutputStream |
FileSystem.create(Path f,
Progressable progress)
Create an FSDataOutputStream at the indicated Path with write-progress
reporting.
|
FSDataOutputStream |
FileSystem.create(Path f,
short replication)
Create an FSDataOutputStream at the indicated Path.
|
FSDataOutputStream |
FileSystem.create(Path f,
short replication,
Progressable progress)
Create an FSDataOutputStream at the indicated Path with write-progress
reporting.
|
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. |
static String[] |
FileUtil.createJarWithClassPath(String inputClassPath,
Path pwd,
Map<String,String> callerEnv) |
static String[] |
FileUtil.createJarWithClassPath(String inputClassPath,
Path pwd,
Path targetDir,
Map<String,String> callerEnv)
Create a jar file at the given path, containing a manifest with a classpath
that references all specified entries.
|
boolean |
FileSystem.createNewFile(Path f)
Creates the given Path as a brand-new zero-length file.
|
FSDataOutputStream |
HarFileSystem.createNonRecursive(Path f,
boolean overwrite,
int bufferSize,
short replication,
long blockSize,
Progressable progress) |
FSDataOutputStream |
FileSystem.createNonRecursive(Path f,
boolean overwrite,
int bufferSize,
short replication,
long blockSize,
Progressable progress)
Opens an FSDataOutputStream at the indicated Path with write-progress
reporting.
|
FSDataOutputStream |
RawLocalFileSystem.createNonRecursive(Path f,
FsPermission permission,
boolean overwrite,
int bufferSize,
short replication,
long blockSize,
Progressable progress) |
FSDataOutputStream |
FileSystem.createNonRecursive(Path f,
FsPermission permission,
boolean overwrite,
int bufferSize,
short replication,
long blockSize,
Progressable progress)
Opens an FSDataOutputStream at the indicated Path with write-progress
reporting.
|
FSDataOutputStream |
ChecksumFileSystem.createNonRecursive(Path f,
FsPermission permission,
boolean overwrite,
int bufferSize,
short replication,
long blockSize,
Progressable progress) |
FSDataOutputStream |
RawLocalFileSystem.createNonRecursive(Path f,
FsPermission permission,
EnumSet<CreateFlag> flags,
int bufferSize,
short replication,
long blockSize,
Progressable progress) |
FSDataOutputStream |
FilterFileSystem.createNonRecursive(Path f,
FsPermission permission,
EnumSet<CreateFlag> flags,
int bufferSize,
short replication,
long blockSize,
Progressable progress) |
FSDataOutputStream |
FileSystem.createNonRecursive(Path f,
FsPermission permission,
EnumSet<CreateFlag> flags,
int bufferSize,
short replication,
long blockSize,
Progressable progress)
Opens an FSDataOutputStream at the indicated Path with write-progress
reporting.
|
protected OutputStream |
RawLocalFileSystem.createOutputStream(Path f,
boolean append) |
protected OutputStream |
RawLocalFileSystem.createOutputStreamWithMode(Path f,
boolean append,
FsPermission permission) |
Path |
FileSystem.createSnapshot(Path path)
Create a snapshot with a default name.
|
Path |
FileContext.createSnapshot(Path path)
Create a snapshot with a default name.
|
Path |
FilterFileSystem.createSnapshot(Path path,
String snapshotName) |
Path |
FileSystem.createSnapshot(Path path,
String snapshotName)
Create a snapshot
|
Path |
FileContext.createSnapshot(Path path,
String snapshotName)
Create a snapshot.
|
Path |
AbstractFileSystem.createSnapshot(Path path,
String snapshotName)
The specification of this method matches that of
FileContext.createSnapshot(Path, String) . |
void |
RawLocalFileSystem.createSymlink(Path target,
Path link,
boolean createParent) |
void |
LocalFileSystem.createSymlink(Path target,
Path link,
boolean createParent) |
void |
FilterFileSystem.createSymlink(Path target,
Path link,
boolean createParent) |
void |
FileSystem.createSymlink(Path target,
Path link,
boolean createParent)
|
void |
FileContext.createSymlink(Path target,
Path link,
boolean createParent)
Creates a symbolic link to an existing file.
|
void |
AbstractFileSystem.createSymlink(Path target,
Path link,
boolean createParent)
The specification of this method matches that of
FileContext.createSymlink(Path, Path, boolean) ; |
boolean |
FileSystem.delete(Path f)
Deprecated.
Use
FileSystem.delete(Path, boolean) instead. |
boolean |
RawLocalFileSystem.delete(Path p,
boolean recursive)
Delete the given path to a file or directory.
|
boolean |
HarFileSystem.delete(Path f,
boolean recursive)
Not implemented.
|
boolean |
FilterFileSystem.delete(Path f,
boolean recursive)
Delete a file
|
abstract boolean |
FileSystem.delete(Path f,
boolean recursive)
Delete a file.
|
boolean |
FileContext.delete(Path f,
boolean recursive)
Delete a file.
|
boolean |
ChecksumFileSystem.delete(Path f,
boolean recursive)
Implement the delete(Path, boolean) in checksum
file system.
|
abstract boolean |
AbstractFileSystem.delete(Path f,
boolean recursive)
The specification of this method matches that of
FileContext.delete(Path, boolean) except that Path f must be for
this file system. |
boolean |
FileSystem.deleteOnExit(Path f)
Mark a path to be deleted when FileSystem is closed.
|
boolean |
FileContext.deleteOnExit(Path f)
Mark a path to be deleted on JVM shutdown.
|
void |
FilterFileSystem.deleteSnapshot(Path path,
String snapshotName) |
void |
FileSystem.deleteSnapshot(Path path,
String snapshotName)
Delete a snapshot of a directory
|
void |
FileContext.deleteSnapshot(Path path,
String snapshotName)
Delete a snapshot of a directory.
|
void |
AbstractFileSystem.deleteSnapshot(Path snapshotDir,
String snapshotName)
The specification of this method matches that of
FileContext.deleteSnapshot(Path, String) . |
boolean |
FileSystem.exists(Path f)
Check if exists.
|
boolean |
FileContext.Util.exists(Path f)
Does the file exist?
Note: Avoid using this method if you already have FileStatus in hand.
|
protected Path |
FileSystem.fixRelativePart(Path p)
|
static void |
FileUtil.fullyDelete(FileSystem fs,
Path dir)
Deprecated.
|
AclStatus |
FilterFileSystem.getAclStatus(Path path) |
AclStatus |
FileSystem.getAclStatus(Path path)
Gets the ACL of a file or directory.
|
AclStatus |
FileContext.getAclStatus(Path path)
Gets the ACLs of files and directories.
|
AclStatus |
AbstractFileSystem.getAclStatus(Path path)
Gets the ACLs of files and directories.
|
long |
FileSystem.getBlockSize(Path f)
Deprecated.
Use getFileStatus() instead
|
Path |
ChecksumFileSystem.getChecksumFile(Path file)
Return the name of the checksum file associated with a file.
|
long |
ChecksumFileSystem.getChecksumFileLength(Path file,
long fileSize)
Return the length of the checksum file given the size of the
actual file.
|
ContentSummary |
FileSystem.getContentSummary(Path f)
Return the
ContentSummary of a given Path . |
ContentSummary |
FileContext.Util.getContentSummary(Path f)
Return the
ContentSummary of path f. |
Path |
TrashPolicy.getCurrentTrashDir(Path path)
Get the current trash directory for path specified based on the Trash
Policy
|
Path |
Trash.getCurrentTrashDir(Path path) |
long |
HarFileSystem.getDefaultBlockSize(Path f) |
long |
FilterFileSystem.getDefaultBlockSize(Path f) |
long |
FileSystem.getDefaultBlockSize(Path f)
Return the number of bytes that large input files should be optimally
be split into to minimize i/o time.
|
short |
HarFileSystem.getDefaultReplication(Path f) |
short |
FilterFileSystem.getDefaultReplication(Path f) |
short |
FileSystem.getDefaultReplication(Path path)
Get the default replication for a path.
|
BlockLocation[] |
FileSystem.getFileBlockLocations(Path p,
long start,
long len)
Return an array containing hostnames, offset and size of
portions of the given file.
|
abstract BlockLocation[] |
AbstractFileSystem.getFileBlockLocations(Path f,
long start,
long len)
The specification of this method matches that of
FileContext.getFileBlockLocations(Path, long, long) except that
Path f must be for this file system. |
FileChecksum |
FilterFileSystem.getFileChecksum(Path f) |
FileChecksum |
FileSystem.getFileChecksum(Path f)
Get the checksum of a file.
|
FileChecksum |
FileContext.getFileChecksum(Path f)
Get the checksum of a file.
|
abstract FileChecksum |
AbstractFileSystem.getFileChecksum(Path f)
The specification of this method matches that of
FileContext.getFileChecksum(Path) except that Path f must be for
this file system. |
FileChecksum |
HarFileSystem.getFileChecksum(Path f,
long length) |
FileChecksum |
FilterFileSystem.getFileChecksum(Path f,
long length) |
FileChecksum |
FileSystem.getFileChecksum(Path f,
long length)
Get the checksum of a file, from the beginning of the file till the
specific length.
|
FileStatus |
RawLocalFileSystem.getFileLinkStatus(Path f)
Return a FileStatus representing the given path.
|
FileStatus |
LocalFileSystem.getFileLinkStatus(Path f) |
FileStatus |
FilterFileSystem.getFileLinkStatus(Path f) |
FileStatus |
FileSystem.getFileLinkStatus(Path f)
|
FileStatus |
FileContext.getFileLinkStatus(Path f)
Return a file status object that represents the path.
|
FileStatus |
AbstractFileSystem.getFileLinkStatus(Path f)
The specification of this method matches that of
FileContext.getFileLinkStatus(Path)
except that an UnresolvedLinkException may be thrown if a symlink is
encountered in the path leading up to the final path component. |
FileStatus |
RawLocalFileSystem.getFileStatus(Path f) |
FileStatus |
HarFileSystem.getFileStatus(Path f)
return the filestatus of files in har archive.
|
FileStatus |
FilterFileSystem.getFileStatus(Path f)
Get file status.
|
abstract FileStatus |
FileSystem.getFileStatus(Path f)
Return a file status object that represents the path.
|
FileStatus |
FileContext.getFileStatus(Path f)
Return a file status object that represents the path.
|
abstract FileStatus |
AbstractFileSystem.getFileStatus(Path f)
The specification of this method matches that of
FileContext.getFileStatus(Path)
except that an UnresolvedLinkException may be thrown if a symlink is
encountered in the path. |
protected AbstractFileSystem |
FileContext.getFSofPath(Path absOrFqPath)
Get the file system of supplied path.
|
protected static FileSystem |
FileSystem.getFSofPath(Path absOrFqPath,
Configuration conf) |
FsStatus |
FileContext.getFsStatus(Path f)
Returns a status object describing the use and capacity of the
file system denoted by the Parh argument p.
|
FsStatus |
AbstractFileSystem.getFsStatus(Path f)
The specification of this method matches that of
FileContext.getFsStatus(Path) except that Path f must be for this
file system. |
static int |
HarFileSystem.getHarHash(Path p)
the hash of the path p inside the filesystem
|
static TrashPolicy |
TrashPolicy.getInstance(Configuration conf,
FileSystem fs,
Path home)
Deprecated.
Use
TrashPolicy.getInstance(Configuration, FileSystem) instead. |
long |
FileSystem.getLength(Path f)
Deprecated.
Use getFileStatus() instead
|
Path |
RawLocalFileSystem.getLinkTarget(Path f) |
Path |
LocalFileSystem.getLinkTarget(Path f) |
Path |
FilterFileSystem.getLinkTarget(Path f) |
Path |
FileSystem.getLinkTarget(Path f)
|
Path |
FileContext.getLinkTarget(Path f)
Returns the target of the given symbolic link as it was specified
when the link was created.
|
Path |
AbstractFileSystem.getLinkTarget(Path f)
Partially resolves the path.
|
static Path |
Path.getPathWithoutSchemeAndAuthority(Path path)
Return a version of the given Path without the scheme information.
|
QuotaUsage |
FileSystem.getQuotaUsage(Path f)
Return the
QuotaUsage of a given Path . |
short |
FileSystem.getReplication(Path src)
Deprecated.
Use getFileStatus() instead
|
FsServerDefaults |
HarFileSystem.getServerDefaults(Path f) |
FsServerDefaults |
FilterFileSystem.getServerDefaults(Path f) |
FsServerDefaults |
FileSystem.getServerDefaults(Path p)
Return a set of server default configuration values
|
FsStatus |
RawLocalFileSystem.getStatus(Path p) |
FsStatus |
HarFileSystem.getStatus(Path p) |
FsStatus |
FilterFileSystem.getStatus(Path p) |
FsStatus |
FileSystem.getStatus(Path p)
Returns a status object describing the use and capacity of the
file system.
|
BlockStoragePolicySpi |
FilterFileSystem.getStoragePolicy(Path src) |
BlockStoragePolicySpi |
FileSystem.getStoragePolicy(Path src)
Query the effective storage policy ID for the given file or directory.
|
BlockStoragePolicySpi |
FileContext.getStoragePolicy(Path path)
Query the effective storage policy ID for the given file or directory.
|
BlockStoragePolicySpi |
AbstractFileSystem.getStoragePolicy(Path src)
Retrieve the storage policy for a given file or directory.
|
Path |
FilterFileSystem.getTrashRoot(Path path) |
Path |
FileSystem.getTrashRoot(Path path)
Get the root directory of Trash for current user when the path specified
is deleted.
|
String |
AbstractFileSystem.getUriPath(Path p)
Get the path-part of a pathname.
|
long |
HarFileSystem.getUsed(Path path)
Return the total size of all files from a specified path.
|
long |
FilterFileSystem.getUsed(Path path)
Return the total size of all files from a specified path.
|
long |
FileSystem.getUsed(Path path)
Return the total size of all files from a specified path.
|
byte[] |
FilterFileSystem.getXAttr(Path path,
String name) |
byte[] |
FileSystem.getXAttr(Path path,
String name)
Get an xattr name and value for a file or directory.
|
byte[] |
FileContext.getXAttr(Path path,
String name)
Get an xattr for a file or directory.
|
byte[] |
AbstractFileSystem.getXAttr(Path path,
String name)
Get an xattr for a file or directory.
|
Map<String,byte[]> |
FilterFileSystem.getXAttrs(Path path) |
Map<String,byte[]> |
FileSystem.getXAttrs(Path path)
Get all of the xattr name/value pairs for a file or directory.
|
Map<String,byte[]> |
FileContext.getXAttrs(Path path)
Get all of the xattrs for a file or directory.
|
Map<String,byte[]> |
AbstractFileSystem.getXAttrs(Path path)
Get all of the xattrs for a file or directory.
|
Map<String,byte[]> |
FilterFileSystem.getXAttrs(Path path,
List<String> names) |
Map<String,byte[]> |
FileSystem.getXAttrs(Path path,
List<String> names)
Get all of the xattrs name/value pairs for a file or directory.
|
Map<String,byte[]> |
FileContext.getXAttrs(Path path,
List<String> names)
Get all of the xattrs for a file or directory.
|
Map<String,byte[]> |
AbstractFileSystem.getXAttrs(Path path,
List<String> names)
Get all of the xattrs for a file or directory.
|
FileStatus[] |
FileSystem.globStatus(Path pathPattern)
Return all the files that match filePattern and are not checksum
files.
|
FileStatus[] |
FileContext.Util.globStatus(Path pathPattern)
Return all the files that match filePattern and are not checksum
files.
|
FileStatus[] |
FileSystem.globStatus(Path pathPattern,
PathFilter filter)
Return an array of FileStatus objects whose path names match pathPattern
and is accepted by the user-supplied path filter.
|
FileStatus[] |
FileContext.Util.globStatus(Path pathPattern,
PathFilter filter)
Return an array of FileStatus objects whose path names match pathPattern
and is accepted by the user-supplied path filter.
|
boolean |
RawLocalFileSystem.handleEmptyDstDirectoryOnWindows(Path src,
File srcFile,
Path dst,
File dstFile) |
abstract void |
TrashPolicy.initialize(Configuration conf,
FileSystem fs,
Path home)
Deprecated.
Use
TrashPolicy.initialize(Configuration, FileSystem) instead. |
static boolean |
ChecksumFileSystem.isChecksumFile(Path file)
Return true iff file is a checksum file name.
|
boolean |
FileSystem.isDirectory(Path f)
True iff the named path is a directory.
|
boolean |
FileSystem.isFile(Path f)
True iff the named path is a regular file.
|
RemoteIterator<Path> |
FilterFileSystem.listCorruptFileBlocks(Path path) |
RemoteIterator<Path> |
FileSystem.listCorruptFileBlocks(Path path) |
RemoteIterator<Path> |
FileContext.listCorruptFileBlocks(Path path) |
RemoteIterator<Path> |
AbstractFileSystem.listCorruptFileBlocks(Path path) |
RemoteIterator<LocatedFileStatus> |
FileSystem.listFiles(Path f,
boolean recursive)
List the statuses and block locations of the files in the given path.
|
RemoteIterator<LocatedFileStatus> |
FileContext.Util.listFiles(Path f,
boolean recursive)
List the statuses and block locations of the files in the given path.
|
RemoteIterator<LocatedFileStatus> |
FilterFileSystem.listLocatedStatus(Path f)
List files and its block locations in a directory.
|
RemoteIterator<LocatedFileStatus> |
FileSystem.listLocatedStatus(Path f)
List the statuses of the files/directories in the given path if the path is
a directory.
|
RemoteIterator<LocatedFileStatus> |
FileContext.listLocatedStatus(Path f)
List the statuses of the files/directories in the given path if the path is
a directory.
|
RemoteIterator<LocatedFileStatus> |
ChecksumFileSystem.listLocatedStatus(Path f)
List the statuses of the files/directories in the given path if the path is
a directory.
|
RemoteIterator<LocatedFileStatus> |
AbstractFileSystem.listLocatedStatus(Path f)
The specification of this method matches that of
FileContext.listLocatedStatus(Path) except that Path f
must be for this file system. |
protected RemoteIterator<LocatedFileStatus> |
FilterFileSystem.listLocatedStatus(Path f,
PathFilter filter) |
protected RemoteIterator<LocatedFileStatus> |
FileSystem.listLocatedStatus(Path f,
PathFilter filter)
Listing a directory
The returned results include its block location if it is a file
The results are filtered by the given path filter
|
FileStatus[] |
RawLocalFileSystem.listStatus(Path f) |
FileStatus[] |
HarFileSystem.listStatus(Path f)
liststatus returns the children of a directory
after looking up the index files.
|
FileStatus[] |
FilterFileSystem.listStatus(Path f)
List files in a directory.
|
abstract FileStatus[] |
FileSystem.listStatus(Path f)
List the statuses of the files/directories in the given path if the path is
a directory.
|
RemoteIterator<FileStatus> |
FileContext.listStatus(Path f)
List the statuses of the files/directories in the given path if the path is
a directory.
|
FileStatus[] |
FileContext.Util.listStatus(Path f)
List the statuses of the files/directories in the given path
if the path is a directory.
|
FileStatus[] |
ChecksumFileSystem.listStatus(Path f)
List the statuses of the files/directories in the given path if the path is
a directory.
|
abstract FileStatus[] |
AbstractFileSystem.listStatus(Path f)
The specification of this method matches that of
FileContext.Util.listStatus(Path) except that Path f must be
for this file system. |
FileStatus[] |
FileSystem.listStatus(Path[] files)
Filter files/directories in the given list of paths using default
path filter.
|
FileStatus[] |
FileContext.Util.listStatus(Path[] files)
|
FileStatus[] |
FileSystem.listStatus(Path[] files,
PathFilter filter)
Filter files/directories in the given list of paths using user-supplied
path filter.
|
FileStatus[] |
FileContext.Util.listStatus(Path[] files,
PathFilter filter)
Filter files/directories in the given list of paths using user-supplied
path filter.
|
FileStatus[] |
FileSystem.listStatus(Path f,
PathFilter filter)
Filter files/directories in the given path using the user-supplied path
filter.
|
FileStatus[] |
FileContext.Util.listStatus(Path f,
PathFilter filter)
Filter files/directories in the given path using the user-supplied path
filter.
|
RemoteIterator<FileStatus> |
FilterFileSystem.listStatusIterator(Path f)
Return a remote iterator for listing in a directory
|
RemoteIterator<FileStatus> |
FileSystem.listStatusIterator(Path p)
Returns a remote iterator so that followup calls are made on demand
while consuming the entries.
|
RemoteIterator<FileStatus> |
AbstractFileSystem.listStatusIterator(Path f)
The specification of this method matches that of
FileContext.listStatus(Path) except that Path f must be for this
file system. |
List<String> |
FilterFileSystem.listXAttrs(Path path) |
List<String> |
FileSystem.listXAttrs(Path path)
Get all of the xattr names for a file or directory.
|
List<String> |
FileContext.listXAttrs(Path path)
Get all of the xattr names for a file or directory.
|
List<String> |
AbstractFileSystem.listXAttrs(Path path)
Get all of the xattr names for a file or directory.
|
Path |
HarFileSystem.makeQualified(Path path) |
Path |
FilterFileSystem.makeQualified(Path path)
Make sure that a path specifies a FileSystem.
|
Path |
FileSystem.makeQualified(Path path)
Make sure that a path specifies a FileSystem.
|
Path |
FileContext.makeQualified(Path path)
Make the path fully qualified if it is isn't.
|
Path |
AbstractFileSystem.makeQualified(Path path)
Make the path fully qualified to this file system
|
static Path |
Path.mergePaths(Path path1,
Path path2)
Merge 2 paths such that the second path is appended relative to the first.
|
void |
FileContext.mkdir(Path dir,
FsPermission permission,
boolean createParent)
Make(create) a directory and all the non-existent parents.
|
abstract void |
AbstractFileSystem.mkdir(Path dir,
FsPermission permission,
boolean createParent)
The specification of this method matches that of
FileContext.mkdir(Path, FsPermission, boolean) except that the Path
f must be fully qualified and the permission is absolute (i.e. |
static boolean |
FileSystem.mkdirs(FileSystem fs,
Path dir,
FsPermission permission)
create a directory with the provided permission
The permission of the directory is set to be the provided permission as in
setPermission, not permission&~umask
|
boolean |
RawLocalFileSystem.mkdirs(Path f)
Creates the specified directory hierarchy.
|
boolean |
FileSystem.mkdirs(Path f)
Call
FileSystem.mkdirs(Path, FsPermission) with default permission. |
boolean |
ChecksumFileSystem.mkdirs(Path f) |
boolean |
RawLocalFileSystem.mkdirs(Path f,
FsPermission permission) |
boolean |
HarFileSystem.mkdirs(Path f,
FsPermission permission)
not implemented.
|
boolean |
FilterFileSystem.mkdirs(Path f,
FsPermission permission) |
abstract boolean |
FileSystem.mkdirs(Path f,
FsPermission permission)
Make the given file and all non-existent parents into
directories.
|
protected boolean |
RawLocalFileSystem.mkOneDirWithMode(Path p,
File p2f,
FsPermission permission) |
void |
FilterFileSystem.modifyAclEntries(Path path,
List<AclEntry> aclSpec) |
void |
FileSystem.modifyAclEntries(Path path,
List<AclEntry> aclSpec)
Modifies ACL entries of files and directories.
|
void |
FileContext.modifyAclEntries(Path path,
List<AclEntry> aclSpec)
Modifies ACL entries of files and directories.
|
void |
ChecksumFileSystem.modifyAclEntries(Path src,
List<AclEntry> aclSpec) |
void |
AbstractFileSystem.modifyAclEntries(Path path,
List<AclEntry> aclSpec)
Modifies ACL entries of files and directories.
|
void |
FileSystem.moveFromLocalFile(Path[] srcs,
Path dst)
The src files is on the local disk.
|
void |
FileSystem.moveFromLocalFile(Path[] srcs,
Path dst)
The src files is on the local disk.
|
void |
RawLocalFileSystem.moveFromLocalFile(Path src,
Path dst) |
void |
FileSystem.moveFromLocalFile(Path src,
Path dst)
The src file is on the local disk.
|
static boolean |
Trash.moveToAppropriateTrash(FileSystem fs,
Path p,
Configuration conf)
In case of the symlinks or mount points, one has to move the appropriate
trashbin in the actual volume of the path p being deleted.
|
void |
FileSystem.moveToLocalFile(Path src,
Path dst)
The src file is under FS, and the dst is on the local disk.
|
abstract boolean |
TrashPolicy.moveToTrash(Path path)
Move a file or directory to the current trash directory.
|
boolean |
Trash.moveToTrash(Path path)
Move a file or directory to the current trash directory.
|
FSDataInputStream |
FileSystem.open(Path f)
Opens an FSDataInputStream at the indicated Path.
|
FSDataInputStream |
FileContext.open(Path f)
Opens an FSDataInputStream at the indicated Path using
default buffersize.
|
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 |
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 |
FileContext.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 |
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. |
File |
RawLocalFileSystem.pathToFile(Path path)
Convert a path to a File.
|
File |
LocalFileSystem.pathToFile(Path path)
Convert a path to a File.
|
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.
|
protected boolean |
FilterFileSystem.primitiveMkdir(Path f,
FsPermission abdolutePermission) |
protected boolean |
FileSystem.primitiveMkdir(Path f,
FsPermission absolutePermission)
Deprecated.
|
protected void |
FileSystem.primitiveMkdir(Path f,
FsPermission absolutePermission,
boolean createParent)
Deprecated.
|
void |
FilterFileSystem.removeAcl(Path path) |
void |
FileSystem.removeAcl(Path path)
Removes all but the base ACL entries of files and directories.
|
void |
FileContext.removeAcl(Path path)
Removes all but the base ACL entries of files and directories.
|
void |
ChecksumFileSystem.removeAcl(Path src) |
void |
AbstractFileSystem.removeAcl(Path path)
Removes all but the base ACL entries of files and directories.
|
void |
FilterFileSystem.removeAclEntries(Path path,
List<AclEntry> aclSpec) |
void |
FileSystem.removeAclEntries(Path path,
List<AclEntry> aclSpec)
Removes ACL entries from files and directories.
|
void |
FileContext.removeAclEntries(Path path,
List<AclEntry> aclSpec)
Removes ACL entries from files and directories.
|
void |
ChecksumFileSystem.removeAclEntries(Path src,
List<AclEntry> aclSpec) |
void |
AbstractFileSystem.removeAclEntries(Path path,
List<AclEntry> aclSpec)
Removes ACL entries from files and directories.
|
void |
FilterFileSystem.removeDefaultAcl(Path path) |
void |
FileSystem.removeDefaultAcl(Path path)
Removes all default ACL entries from files and directories.
|
void |
FileContext.removeDefaultAcl(Path path)
Removes all default ACL entries from files and directories.
|
void |
ChecksumFileSystem.removeDefaultAcl(Path src) |
void |
AbstractFileSystem.removeDefaultAcl(Path path)
Removes all default ACL entries from files and directories.
|
void |
FilterFileSystem.removeXAttr(Path path,
String name) |
void |
FileSystem.removeXAttr(Path path,
String name)
Remove an xattr of a file or directory.
|
void |
FileContext.removeXAttr(Path path,
String name)
Remove an xattr of a file or directory.
|
void |
AbstractFileSystem.removeXAttr(Path path,
String name)
Remove an xattr of a file or directory.
|
boolean |
RawLocalFileSystem.rename(Path src,
Path dst) |
boolean |
HarFileSystem.rename(Path src,
Path dst) |
boolean |
FilterFileSystem.rename(Path src,
Path dst)
Renames Path src to Path dst.
|
abstract boolean |
FileSystem.rename(Path src,
Path dst)
Renames Path src to Path dst.
|
boolean |
ChecksumFileSystem.rename(Path src,
Path dst)
Rename files/dirs
|
protected void |
FileSystem.rename(Path src,
Path dst,
Options.Rename... options)
Deprecated.
|
void |
FileContext.rename(Path src,
Path dst,
Options.Rename... options)
Renames Path src to Path dst
|
void |
AbstractFileSystem.rename(Path src,
Path dst,
Options.Rename... options)
The specification of this method matches that of
FileContext.rename(Path, Path, Options.Rename...) except that Path
f must be for this file system. |
abstract void |
AbstractFileSystem.renameInternal(Path src,
Path dst)
The specification of this method matches that of
FileContext.rename(Path, Path, Options.Rename...) except that Path
f must be for this file system and NO OVERWRITE is performed. |
void |
AbstractFileSystem.renameInternal(Path src,
Path dst,
boolean overwrite)
The specification of this method matches that of
FileContext.rename(Path, Path, Options.Rename...) except that Path
f must be for this file system. |
void |
FilterFileSystem.renameSnapshot(Path path,
String snapshotOldName,
String snapshotNewName) |
void |
FileSystem.renameSnapshot(Path path,
String snapshotOldName,
String snapshotNewName)
Rename a snapshot
|
void |
FileContext.renameSnapshot(Path path,
String snapshotOldName,
String snapshotNewName)
Rename a snapshot.
|
void |
AbstractFileSystem.renameSnapshot(Path path,
String snapshotOldName,
String snapshotNewName)
The specification of this method matches that of
FileContext.renameSnapshot(Path, String, String) . |
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.
|
protected Path |
FileContext.resolve(Path f)
Resolves all symbolic links in the specified path.
|
protected Path |
FileContext.resolveIntermediate(Path f)
Resolves all symbolic links in the specified path leading up
to, but not including the final path component.
|
protected Path |
FilterFileSystem.resolveLink(Path f) |
protected Path |
FileSystem.resolveLink(Path f)
|
Path |
HarFileSystem.resolvePath(Path p) |
Path |
FilterFileSystem.resolvePath(Path p) |
Path |
FileSystem.resolvePath(Path p)
Return the fully-qualified path of path f resolving the path
through any symlinks or mount point
|
Path |
FileContext.resolvePath(Path f)
Resolve the path following any symlinks or mount points
|
Path |
AbstractFileSystem.resolvePath(Path p)
Return the fully-qualified path of path f resolving the path
through any internal symlinks or mount point
|
void |
FilterFileSystem.setAcl(Path path,
List<AclEntry> aclSpec) |
void |
FileSystem.setAcl(Path path,
List<AclEntry> aclSpec)
Fully replaces ACL of files and directories, discarding all existing
entries.
|
void |
FileContext.setAcl(Path path,
List<AclEntry> aclSpec)
Fully replaces ACL of files and directories, discarding all existing
entries.
|
void |
ChecksumFileSystem.setAcl(Path src,
List<AclEntry> aclSpec) |
void |
AbstractFileSystem.setAcl(Path path,
List<AclEntry> aclSpec)
Fully replaces ACL of files and directories, discarding all existing
entries.
|
void |
RawLocalFileSystem.setOwner(Path p,
String username,
String groupname)
Use the command chown to set owner.
|
void |
HarFileSystem.setOwner(Path p,
String username,
String groupname)
not implemented.
|
void |
FilterFileSystem.setOwner(Path p,
String username,
String groupname) |
void |
FileSystem.setOwner(Path p,
String username,
String groupname)
Set owner of a path (i.e.
|
void |
FileContext.setOwner(Path f,
String username,
String groupname)
Set owner of a path (i.e.
|
void |
ChecksumFileSystem.setOwner(Path src,
String username,
String groupname) |
abstract void |
AbstractFileSystem.setOwner(Path f,
String username,
String groupname)
The specification of this method matches that of
FileContext.setOwner(Path, String, String) except that Path f must
be for this file system. |
void |
FileStatus.setPath(Path p) |
void |
RawLocalFileSystem.setPermission(Path p,
FsPermission permission)
Use the command chmod to set permission.
|
void |
HarFileSystem.setPermission(Path p,
FsPermission permission)
Not implemented.
|
void |
FilterFileSystem.setPermission(Path p,
FsPermission permission) |
void |
FileSystem.setPermission(Path p,
FsPermission permission)
Set permission of a path.
|
void |
FileContext.setPermission(Path f,
FsPermission permission)
Set permission of a path.
|
void |
ChecksumFileSystem.setPermission(Path src,
FsPermission permission) |
abstract void |
AbstractFileSystem.setPermission(Path f,
FsPermission permission)
The specification of this method matches that of
FileContext.setPermission(Path, FsPermission) except that Path f
must be for this file system. |
boolean |
HarFileSystem.setReplication(Path src,
short replication)
Not implemented.
|
boolean |
FilterFileSystem.setReplication(Path src,
short replication)
Set replication for an existing file.
|
boolean |
FileSystem.setReplication(Path src,
short replication)
Set replication for an existing file.
|
boolean |
FileContext.setReplication(Path f,
short replication)
Set replication for an existing file.
|
boolean |
ChecksumFileSystem.setReplication(Path src,
short replication)
Set replication for an existing file.
|
abstract boolean |
AbstractFileSystem.setReplication(Path f,
short replication)
The specification of this method matches that of
FileContext.setReplication(Path, short) except that Path f must be
for this file system. |
void |
FilterFileSystem.setStoragePolicy(Path src,
String policyName) |
void |
FileSystem.setStoragePolicy(Path src,
String policyName)
Set the storage policy for a given file or directory.
|
void |
FileContext.setStoragePolicy(Path path,
String policyName)
Set the storage policy for a given file or directory.
|
void |
AbstractFileSystem.setStoragePolicy(Path path,
String policyName)
Set the storage policy for a given file or directory.
|
void |
FileStatus.setSymlink(Path p) |
void |
RawLocalFileSystem.setTimes(Path p,
long mtime,
long atime)
Sets the
Path 's last modified time and last access time to
the given valid times. |
void |
HarFileSystem.setTimes(Path p,
long mtime,
long atime) |
void |
FilterFileSystem.setTimes(Path p,
long mtime,
long atime) |
void |
FileSystem.setTimes(Path p,
long mtime,
long atime)
Set access time of a file
|
void |
FileContext.setTimes(Path f,
long mtime,
long atime)
Set access time of a file.
|
abstract void |
AbstractFileSystem.setTimes(Path f,
long mtime,
long atime)
The specification of this method matches that of
FileContext.setTimes(Path, long, long) except that Path f must be
for this file system. |
void |
FileContext.setVerifyChecksum(boolean verifyChecksum,
Path f)
Set the verify checksum flag for the file system denoted by the path.
|
void |
RawLocalFileSystem.setWorkingDirectory(Path newDir)
Set the working directory to the given directory.
|
void |
HarFileSystem.setWorkingDirectory(Path newDir) |
void |
FilterFileSystem.setWorkingDirectory(Path newDir)
Set the current working directory for the given file system.
|
abstract void |
FileSystem.setWorkingDirectory(Path new_dir)
Set the current working directory for the given file system.
|
void |
FileContext.setWorkingDirectory(Path newWDir)
Set the working directory for wd-relative names (such a "foo/bar").
|
void |
FilterFileSystem.setXAttr(Path path,
String name,
byte[] value) |
void |
FileSystem.setXAttr(Path path,
String name,
byte[] value)
Set an xattr of a file or directory.
|
void |
FileContext.setXAttr(Path path,
String name,
byte[] value)
Set an xattr of a file or directory.
|
void |
AbstractFileSystem.setXAttr(Path path,
String name,
byte[] value)
Set an xattr of a file or directory.
|
void |
FilterFileSystem.setXAttr(Path path,
String name,
byte[] value,
EnumSet<XAttrSetFlag> flag) |
void |
FileSystem.setXAttr(Path path,
String name,
byte[] value,
EnumSet<XAttrSetFlag> flag)
Set an xattr of a file or directory.
|
void |
FileContext.setXAttr(Path path,
String name,
byte[] value,
EnumSet<XAttrSetFlag> flag)
Set an xattr of a file or directory.
|
void |
AbstractFileSystem.setXAttr(Path path,
String name,
byte[] value,
EnumSet<XAttrSetFlag> flag)
Set an xattr of a file or directory.
|
Path |
RawLocalFileSystem.startLocalOutput(Path fsOutputFile,
Path tmpLocalFile) |
Path |
HarFileSystem.startLocalOutput(Path fsOutputFile,
Path tmpLocalFile)
not implemented.
|
Path |
FilterFileSystem.startLocalOutput(Path fsOutputFile,
Path tmpLocalFile)
Returns a local File that the user can write output to.
|
Path |
FileSystem.startLocalOutput(Path fsOutputFile,
Path tmpLocalFile)
Returns a local File that the user can write output to.
|
Path |
ChecksumFileSystem.startLocalOutput(Path fsOutputFile,
Path tmpLocalFile) |
static Path[] |
FileUtil.stat2Paths(FileStatus[] stats,
Path path)
convert an array of FileStatus to an array of Path.
|
boolean |
RawLocalFileSystem.truncate(Path f,
long newLength) |
boolean |
HarFileSystem.truncate(Path f,
long newLength)
Not implemented.
|
boolean |
FilterFileSystem.truncate(Path f,
long newLength) |
boolean |
FileSystem.truncate(Path f,
long newLength)
Truncate the file in the indicated path to the indicated size.
|
boolean |
FileContext.truncate(Path f,
long newLength)
Truncate the file in the indicated path to the indicated size.
|
boolean |
ChecksumFileSystem.truncate(Path f,
long newLength) |
boolean |
AbstractFileSystem.truncate(Path f,
long newLength)
The specification of this method matches that of
FileContext.truncate(Path, long) except that Path f must be for
this file system. |
void |
FilterFileSystem.unsetStoragePolicy(Path src) |
void |
FileSystem.unsetStoragePolicy(Path src)
Unset the storage policy set for a given file or directory.
|
void |
FileContext.unsetStoragePolicy(Path src)
Unset the storage policy set for a given file or directory.
|
void |
AbstractFileSystem.unsetStoragePolicy(Path src)
Unset the storage policy set for a given file or directory.
|
Constructor and Description |
---|
AvroFSInput(FileContext fc,
Path p)
Construct given a
FileContext and a Path . |
FileStatus(long length,
boolean isdir,
int block_replication,
long blocksize,
long modification_time,
long access_time,
FsPermission permission,
String owner,
String group,
Path path)
Constructor for file systems on which symbolic links are not supported
|
FileStatus(long length,
boolean isdir,
int block_replication,
long blocksize,
long modification_time,
long access_time,
FsPermission permission,
String owner,
String group,
Path symlink,
Path path) |
FileStatus(long length,
boolean isdir,
int block_replication,
long blocksize,
long modification_time,
Path path) |
LocatedFileStatus(long length,
boolean isdir,
int block_replication,
long blocksize,
long modification_time,
long access_time,
FsPermission permission,
String owner,
String group,
Path symlink,
Path path,
BlockLocation[] locations)
Constructor
|
Path(Path parent,
Path child)
Create a new Path based on the child path resolved against the parent path.
|
Path(Path parent,
String child)
Create a new Path based on the child path resolved against the parent path.
|
Path(String parent,
Path child)
Create a new Path based on the child path resolved against the parent path.
|
Modifier and Type | Method and Description |
---|---|
Path |
FTPFileSystem.getHomeDirectory() |
Path |
FTPFileSystem.getWorkingDirectory() |
Modifier and Type | Method and Description |
---|---|
FSDataOutputStream |
FTPFileSystem.append(Path f,
int bufferSize,
Progressable progress)
This optional operation is not yet supported.
|
FSDataOutputStream |
FTPFileSystem.create(Path file,
FsPermission permission,
boolean overwrite,
int bufferSize,
short replication,
long blockSize,
Progressable progress)
A stream obtained via this call must be closed before using other APIs of
this class or else the invocation will block.
|
boolean |
FTPFileSystem.delete(Path file,
boolean recursive) |
FileStatus |
FTPFileSystem.getFileStatus(Path file) |
FileStatus[] |
FTPFileSystem.listStatus(Path file) |
boolean |
FTPFileSystem.mkdirs(Path file,
FsPermission permission) |
FSDataInputStream |
FTPFileSystem.open(Path file,
int bufferSize) |
boolean |
FTPFileSystem.rename(Path src,
Path dst) |
void |
FTPFileSystem.setWorkingDirectory(Path newDir) |
Modifier and Type | Method and Description |
---|---|
Path |
SFTPFileSystem.getHomeDirectory() |
Path |
SFTPFileSystem.getWorkingDirectory() |
Modifier and Type | Method and Description |
---|---|
FSDataOutputStream |
SFTPFileSystem.append(Path f,
int bufferSize,
Progressable progress) |
FSDataOutputStream |
SFTPFileSystem.create(Path f,
FsPermission permission,
boolean overwrite,
int bufferSize,
short replication,
long blockSize,
Progressable progress)
A stream obtained via this call must be closed before using other APIs of
this class or else the invocation will block.
|
boolean |
SFTPFileSystem.delete(Path f,
boolean recursive) |
FileStatus |
SFTPFileSystem.getFileStatus(Path f) |
FileStatus[] |
SFTPFileSystem.listStatus(Path f) |
boolean |
SFTPFileSystem.mkdirs(Path f,
FsPermission permission) |
FSDataInputStream |
SFTPFileSystem.open(Path f,
int bufferSize) |
boolean |
SFTPFileSystem.rename(Path src,
Path dst) |
void |
SFTPFileSystem.setWorkingDirectory(Path newDir) |
Modifier and Type | Method and Description |
---|---|
protected Path |
BaseExpression.getPath(org.apache.hadoop.fs.shell.PathData item)
Returns the
Path from the PathData item. |
Modifier and Type | Method and Description |
---|---|
Path |
ViewFs.createSnapshot(Path path,
String snapshotName) |
Path |
ViewFileSystem.createSnapshot(Path path,
String snapshotName) |
Path |
ViewFs.getHomeDirectory() |
Path |
ViewFileSystem.getHomeDirectory() |
Path |
ViewFs.getLinkTarget(Path f) |
Path |
ViewFileSystem.getTrashCanLocation(Path f) |
Path |
ViewFileSystem.getWorkingDirectory() |
Path |
ViewFs.resolvePath(Path f) |
Path |
ViewFileSystem.resolvePath(Path f) |
Modifier and Type | Method and Description |
---|---|
void |
ViewFs.access(Path path,
FsAction mode) |
void |
ViewFileSystem.access(Path path,
FsAction mode) |
FSDataOutputStream |
ViewFileSystem.append(Path f,
int bufferSize,
Progressable progress) |
FSDataOutputStream |
ViewFileSystem.create(Path f,
FsPermission permission,
boolean overwrite,
int bufferSize,
short replication,
long blockSize,
Progressable progress) |
FSDataOutputStream |
ViewFs.createInternal(Path f,
EnumSet<CreateFlag> flag,
FsPermission absolutePermission,
int bufferSize,
short replication,
long blockSize,
Progressable progress,
Options.ChecksumOpt checksumOpt,
boolean createParent) |
FSDataOutputStream |
ViewFileSystem.createNonRecursive(Path f,
FsPermission permission,
EnumSet<CreateFlag> flags,
int bufferSize,
short replication,
long blockSize,
Progressable progress) |
Path |
ViewFs.createSnapshot(Path path,
String snapshotName) |
Path |
ViewFileSystem.createSnapshot(Path path,
String snapshotName) |
void |
ViewFs.createSymlink(Path target,
Path link,
boolean createParent) |
boolean |
ViewFileSystem.delete(Path f) |
boolean |
ViewFs.delete(Path f,
boolean recursive) |
boolean |
ViewFileSystem.delete(Path f,
boolean recursive) |
void |
ViewFs.deleteSnapshot(Path path,
String snapshotName) |
void |
ViewFileSystem.deleteSnapshot(Path path,
String snapshotName) |
AclStatus |
ViewFs.getAclStatus(Path path) |
AclStatus |
ViewFileSystem.getAclStatus(Path path) |
ContentSummary |
ViewFileSystem.getContentSummary(Path f) |
long |
ViewFileSystem.getDefaultBlockSize(Path f) |
short |
ViewFileSystem.getDefaultReplication(Path f) |
BlockLocation[] |
ViewFs.getFileBlockLocations(Path f,
long start,
long len) |
FileChecksum |
ViewFs.getFileChecksum(Path f) |
FileChecksum |
ViewFileSystem.getFileChecksum(Path f) |
FileStatus |
ViewFs.getFileLinkStatus(Path f) |
FileStatus |
ViewFs.getFileStatus(Path f) |
FileStatus |
ViewFileSystem.getFileStatus(Path f) |
Path |
ViewFs.getLinkTarget(Path f) |
QuotaUsage |
ViewFileSystem.getQuotaUsage(Path f) |
FsServerDefaults |
ViewFileSystem.getServerDefaults(Path f) |
BlockStoragePolicySpi |
ViewFs.getStoragePolicy(Path src)
Retrieve the storage policy for a given file or directory.
|
Path |
ViewFileSystem.getTrashCanLocation(Path f) |
byte[] |
ViewFs.getXAttr(Path path,
String name) |
byte[] |
ViewFileSystem.getXAttr(Path path,
String name) |
Map<String,byte[]> |
ViewFs.getXAttrs(Path path) |
Map<String,byte[]> |
ViewFileSystem.getXAttrs(Path path) |
Map<String,byte[]> |
ViewFs.getXAttrs(Path path,
List<String> names) |
Map<String,byte[]> |
ViewFileSystem.getXAttrs(Path path,
List<String> names) |
RemoteIterator<LocatedFileStatus> |
ViewFileSystem.listLocatedStatus(Path f,
PathFilter filter) |
FileStatus[] |
ViewFs.listStatus(Path f) |
FileStatus[] |
ViewFileSystem.listStatus(Path f) |
RemoteIterator<FileStatus> |
ViewFs.listStatusIterator(Path f) |
List<String> |
ViewFs.listXAttrs(Path path) |
List<String> |
ViewFileSystem.listXAttrs(Path path) |
void |
ViewFs.mkdir(Path dir,
FsPermission permission,
boolean createParent) |
boolean |
ViewFileSystem.mkdirs(Path dir,
FsPermission permission) |
void |
ViewFs.modifyAclEntries(Path path,
List<AclEntry> aclSpec) |
void |
ViewFileSystem.modifyAclEntries(Path path,
List<AclEntry> aclSpec) |
FSDataInputStream |
ViewFs.open(Path f,
int bufferSize) |
FSDataInputStream |
ViewFileSystem.open(Path f,
int bufferSize) |
void |
ViewFs.removeAcl(Path path) |
void |
ViewFileSystem.removeAcl(Path path) |
void |
ViewFs.removeAclEntries(Path path,
List<AclEntry> aclSpec) |
void |
ViewFileSystem.removeAclEntries(Path path,
List<AclEntry> aclSpec) |
void |
ViewFs.removeDefaultAcl(Path path) |
void |
ViewFileSystem.removeDefaultAcl(Path path) |
void |
ViewFs.removeXAttr(Path path,
String name) |
void |
ViewFileSystem.removeXAttr(Path path,
String name) |
boolean |
ViewFileSystem.rename(Path src,
Path dst) |
void |
ViewFs.renameInternal(Path src,
Path dst) |
void |
ViewFs.renameInternal(Path src,
Path dst,
boolean overwrite) |
void |
ViewFs.renameSnapshot(Path path,
String snapshotOldName,
String snapshotNewName) |
void |
ViewFileSystem.renameSnapshot(Path path,
String snapshotOldName,
String snapshotNewName) |
Path |
ViewFs.resolvePath(Path f) |
Path |
ViewFileSystem.resolvePath(Path f) |
void |
ViewFs.setAcl(Path path,
List<AclEntry> aclSpec) |
void |
ViewFileSystem.setAcl(Path path,
List<AclEntry> aclSpec) |
void |
ViewFs.setOwner(Path f,
String username,
String groupname) |
void |
ViewFileSystem.setOwner(Path f,
String username,
String groupname) |
void |
ViewFs.setPermission(Path f,
FsPermission permission) |
void |
ViewFileSystem.setPermission(Path f,
FsPermission permission) |
boolean |
ViewFs.setReplication(Path f,
short replication) |
boolean |
ViewFileSystem.setReplication(Path f,
short replication) |
void |
ViewFs.setStoragePolicy(Path path,
String policyName) |
void |
ViewFs.setTimes(Path f,
long mtime,
long atime) |
void |
ViewFileSystem.setTimes(Path f,
long mtime,
long atime) |
void |
ViewFileSystem.setWorkingDirectory(Path new_dir) |
void |
ViewFs.setXAttr(Path path,
String name,
byte[] value,
EnumSet<XAttrSetFlag> flag) |
void |
ViewFileSystem.setXAttr(Path path,
String name,
byte[] value,
EnumSet<XAttrSetFlag> flag) |
boolean |
ViewFs.truncate(Path f,
long newLength) |
boolean |
ViewFileSystem.truncate(Path f,
long newLength) |
void |
ViewFs.unsetStoragePolicy(Path src) |
Constructor and Description |
---|
NotInMountpointException(Path path,
String operation) |
Modifier and Type | Method and Description |
---|---|
SequenceFile.Writer |
SequenceFile.Sorter.cloneFileAttributes(Path inputFile,
Path outputFile,
Progressable prog)
Clones the attributes (like compression of the input file and creates a
corresponding Writer
|
protected SequenceFile.Reader |
MapFile.Reader.createDataFileReader(Path dataFile,
Configuration conf,
SequenceFile.Reader.Option... options)
Override this method to specialize the type of
SequenceFile.Reader returned. |
static SequenceFile.Writer |
SequenceFile.createWriter(FileContext fc,
Configuration conf,
Path name,
Class keyClass,
Class valClass,
SequenceFile.CompressionType compressionType,
CompressionCodec codec,
SequenceFile.Metadata metadata,
EnumSet<CreateFlag> createFlag,
Options.CreateOpts... opts)
Construct the preferred type of SequenceFile Writer.
|
static SequenceFile.Writer |
SequenceFile.createWriter(FileSystem fs,
Configuration conf,
Path name,
Class keyClass,
Class valClass)
Deprecated.
|
static SequenceFile.Writer |
SequenceFile.createWriter(FileSystem fs,
Configuration conf,
Path name,
Class keyClass,
Class valClass,
int bufferSize,
short replication,
long blockSize,
boolean createParent,
SequenceFile.CompressionType compressionType,
CompressionCodec codec,
SequenceFile.Metadata metadata)
Deprecated.
|
static SequenceFile.Writer |
SequenceFile.createWriter(FileSystem fs,
Configuration conf,
Path name,
Class keyClass,
Class valClass,
int bufferSize,
short replication,
long blockSize,
SequenceFile.CompressionType compressionType,
CompressionCodec codec,
Progressable progress,
SequenceFile.Metadata metadata)
Deprecated.
|
static SequenceFile.Writer |
SequenceFile.createWriter(FileSystem fs,
Configuration conf,
Path name,
Class keyClass,
Class valClass,
SequenceFile.CompressionType compressionType)
Deprecated.
|
static SequenceFile.Writer |
SequenceFile.createWriter(FileSystem fs,
Configuration conf,
Path name,
Class keyClass,
Class valClass,
SequenceFile.CompressionType compressionType,
CompressionCodec codec)
Deprecated.
|
static SequenceFile.Writer |
SequenceFile.createWriter(FileSystem fs,
Configuration conf,
Path name,
Class keyClass,
Class valClass,
SequenceFile.CompressionType compressionType,
CompressionCodec codec,
Progressable progress)
Deprecated.
|
static SequenceFile.Writer |
SequenceFile.createWriter(FileSystem fs,
Configuration conf,
Path name,
Class keyClass,
Class valClass,
SequenceFile.CompressionType compressionType,
CompressionCodec codec,
Progressable progress,
SequenceFile.Metadata metadata)
Deprecated.
|
static SequenceFile.Writer |
SequenceFile.createWriter(FileSystem fs,
Configuration conf,
Path name,
Class keyClass,
Class valClass,
SequenceFile.CompressionType compressionType,
Progressable progress)
Deprecated.
|
static SequenceFile.Writer.Option |
SequenceFile.Writer.file(Path value) |
static SequenceFile.Reader.Option |
SequenceFile.Reader.file(Path value)
Create an option to specify the path name of the sequence file.
|
static long |
MapFile.fix(FileSystem fs,
Path dir,
Class<? extends Writable> keyClass,
Class<? extends Writable> valueClass,
boolean dryrun,
Configuration conf)
This method attempts to fix a corrupt MapFile by re-creating its index.
|
SequenceFile.Sorter.RawKeyValueIterator |
SequenceFile.Sorter.merge(List<SequenceFile.Sorter.SegmentDescriptor> segments,
Path tmpDir)
Merges the list of segments of type
SegmentDescriptor |
SequenceFile.Sorter.RawKeyValueIterator |
SequenceFile.Sorter.merge(Path[] inNames,
boolean deleteInputs,
int factor,
Path tmpDir)
Merges the contents of files passed in Path[]
|
SequenceFile.Sorter.RawKeyValueIterator |
SequenceFile.Sorter.merge(Path[] inNames,
boolean deleteInputs,
int factor,
Path tmpDir)
Merges the contents of files passed in Path[]
|
SequenceFile.Sorter.RawKeyValueIterator |
SequenceFile.Sorter.merge(Path[] inNames,
boolean deleteInputs,
Path tmpDir)
Merges the contents of files passed in Path[] using a max factor value
that is already set
|
SequenceFile.Sorter.RawKeyValueIterator |
SequenceFile.Sorter.merge(Path[] inNames,
boolean deleteInputs,
Path tmpDir)
Merges the contents of files passed in Path[] using a max factor value
that is already set
|
void |
MapFile.Merger.merge(Path[] inMapFiles,
boolean deleteInputs,
Path outMapFile)
Merge multiple MapFiles to one Mapfile
|
void |
MapFile.Merger.merge(Path[] inMapFiles,
boolean deleteInputs,
Path outMapFile)
Merge multiple MapFiles to one Mapfile
|
void |
SequenceFile.Sorter.merge(Path[] inFiles,
Path outFile)
Merge the provided files.
|
void |
SequenceFile.Sorter.merge(Path[] inFiles,
Path outFile)
Merge the provided files.
|
SequenceFile.Sorter.RawKeyValueIterator |
SequenceFile.Sorter.merge(Path[] inNames,
Path tempDir,
boolean deleteInputs)
Merges the contents of files passed in Path[]
|
SequenceFile.Sorter.RawKeyValueIterator |
SequenceFile.Sorter.merge(Path[] inNames,
Path tempDir,
boolean deleteInputs)
Merges the contents of files passed in Path[]
|
protected void |
MapFile.Reader.open(Path dir,
WritableComparator comparator,
Configuration conf,
SequenceFile.Reader.Option... options) |
protected FSDataInputStream |
SequenceFile.Reader.openFile(FileSystem fs,
Path file,
int bufferSize,
long length)
Override this method to specialize the type of
FSDataInputStream returned. |
void |
SequenceFile.Sorter.sort(Path[] inFiles,
Path outFile,
boolean deleteInput)
Perform a file sort from a set of input files into an output file.
|
void |
SequenceFile.Sorter.sort(Path[] inFiles,
Path outFile,
boolean deleteInput)
Perform a file sort from a set of input files into an output file.
|
void |
SequenceFile.Sorter.sort(Path inFile,
Path outFile)
The backwards compatible interface to sort.
|
SequenceFile.Sorter.RawKeyValueIterator |
SequenceFile.Sorter.sortAndIterate(Path[] inFiles,
Path tempDir,
boolean deleteInput)
Perform a file sort from a set of input files and return an iterator.
|
SequenceFile.Sorter.RawKeyValueIterator |
SequenceFile.Sorter.sortAndIterate(Path[] inFiles,
Path tempDir,
boolean deleteInput)
Perform a file sort from a set of input files and return an iterator.
|
Constructor and Description |
---|
BloomMapFile.Reader(Path dir,
Configuration conf,
SequenceFile.Reader.Option... options) |
BloomMapFile.Writer(Configuration conf,
Path dir,
SequenceFile.Writer.Option... options) |
MapFile.Reader(Path dir,
Configuration conf,
SequenceFile.Reader.Option... opts) |
MapFile.Writer(Configuration conf,
Path dirName,
SequenceFile.Writer.Option... opts) |
SequenceFile.Reader(FileSystem fs,
Path file,
Configuration conf)
Deprecated.
Use Reader(Configuration, Option...) instead.
|
SequenceFile.Sorter.SegmentDescriptor(long segmentOffset,
long segmentLength,
Path segmentPathName)
Constructs a segment
|
SequenceFile.Writer(FileSystem fs,
Configuration conf,
Path name,
Class keyClass,
Class valClass)
Deprecated.
|
SequenceFile.Writer(FileSystem fs,
Configuration conf,
Path name,
Class keyClass,
Class valClass,
int bufferSize,
short replication,
long blockSize,
Progressable progress,
SequenceFile.Metadata metadata)
Deprecated.
|
SequenceFile.Writer(FileSystem fs,
Configuration conf,
Path name,
Class keyClass,
Class valClass,
Progressable progress,
SequenceFile.Metadata metadata)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
CompressionCodec |
CompressionCodecFactory.getCodec(Path file)
Find the relevant compression codec for the given file based on its
filename suffix.
|
Modifier and Type | Method and Description |
---|---|
static Path |
ProviderUtils.unnestUri(URI nestedUri)
Convert a nested URI to decode the underlying path.
|
Modifier and Type | Method and Description |
---|---|
static Credentials |
Credentials.readTokenStorageFile(Path filename,
Configuration conf)
Convenience method for reading a token storage file, and loading the Tokens
therein in the passed UGI
|
void |
Credentials.writeTokenStorageFile(Path filename,
Configuration conf) |
Modifier and Type | Method and Description |
---|---|
Path |
Options.PathOption.getValue() |
Constructor and Description |
---|
Options.PathOption(Path value) |
Copyright © 2017 Apache Software Foundation. All Rights Reserved.