Package | Description |
---|---|
org.apache.hadoop.fs |
An abstract file system API.
|
org.apache.hadoop.fs.viewfs | |
org.apache.hadoop.ha | |
org.apache.hadoop.ha.protocolPB | |
org.apache.hadoop.hdfs |
A distributed implementation of
FileSystem . |
org.apache.hadoop.hdfs.protocol | |
org.apache.hadoop.hdfs.protocolPB | |
org.apache.hadoop.hdfs.server.namenode | |
org.apache.hadoop.hdfs.tools | |
org.apache.hadoop.security.authorize | |
org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity |
Modifier and Type | Method and Description |
---|---|
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.
|
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 |
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.
|
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. |
void |
FilterFileSystem.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 |
FileSystem.createSymlink(Path target,
Path link,
boolean createParent)
|
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 |
FileContext.delete(Path f,
boolean recursive)
Delete a file.
|
boolean |
FileContext.deleteOnExit(Path f)
Mark a path to be deleted on JVM shutdown.
|
boolean |
FileContext.Util.exists(Path f)
Does the file exist?
Note: Avoid using this method if you already have FileStatus in hand.
|
ContentSummary |
FileContext.Util.getContentSummary(Path f)
Return the
ContentSummary of path f. |
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. |
BlockLocation[] |
FileContext.getFileBlockLocations(Path f,
long start,
long len)
Return blockLocation of the given file for the given offset and len.
|
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 |
FileContext.getFileChecksum(Path f)
Get the checksum of a file.
|
FileStatus |
FilterFileSystem.getFileLinkStatus(Path f) |
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 |
FileContext.getFileLinkStatus(Path f)
Return a file status object that represents the path.
|
FileStatus |
FileSystem.getFileLinkStatus(Path f)
|
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. |
FileStatus |
FileContext.getFileStatus(Path f)
Return a file status object that represents the path.
|
abstract FsStatus |
AbstractFileSystem.getFsStatus()
The specification of this method matches that of
FileContext.getFsStatus(Path) . |
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. |
FsStatus |
FilterFs.getFsStatus(Path f) |
FsStatus |
FileContext.getFsStatus(Path f)
Returns a status object describing the use and capacity of the
file system denoted by the Parh argument p.
|
Path |
FileContext.getLinkTarget(Path f)
Returns the target of the given symbolic link as it was specified
when the link was created.
|
FileStatus[] |
FileContext.Util.globStatus(Path pathPattern)
Return all the files that match filePattern and are not checksum
files.
|
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.
|
RemoteIterator<LocatedFileStatus> |
FileContext.Util.listFiles(Path f,
boolean recursive)
List the statuses and block locations of the files in the given path.
|
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. |
RemoteIterator<LocatedFileStatus> |
FileContext.listLocatedStatus(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. |
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[] |
FileContext.Util.listStatus(Path[] files)
|
FileStatus[] |
FileContext.Util.listStatus(Path[] files,
PathFilter filter)
Filter files/directories in the given list of paths using 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> |
Hdfs.listStatusIterator(Path f) |
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. |
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. |
void |
FileContext.mkdir(Path dir,
FsPermission permission,
boolean createParent)
Make(create) a directory and all the non-existent parents.
|
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 |
FilterFs.open(Path f) |
FSDataInputStream |
FileContext.open(Path f)
Opens an FSDataInputStream at the indicated Path using
default 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.
|
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. |
void |
FileContext.rename(Path src,
Path dst,
Options.Rename... options)
Renames Path src to Path dst
|
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 |
FilterFs.renameInternal(Path src,
Path dst,
boolean overwrite) |
protected Path |
FileContext.resolve(Path f)
Resolves all symbolic links in the specified path.
|
Path |
AbstractFileSystem.resolvePath(Path p)
Return the fully-qualified path of path f resolving the path
through any internal symlinks or mount point
|
Path |
FilterFs.resolvePath(Path p) |
Path |
FileContext.resolvePath(Path f)
Resolve the path following any symlinks or mount points
|
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 |
FileContext.setOwner(Path f,
String username,
String groupname)
Set owner of a path (i.e.
|
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. |
void |
FileContext.setPermission(Path f,
FsPermission permission)
Set permission of a path.
|
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. |
boolean |
FileContext.setReplication(Path f,
short replication)
Set replication for an existing 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.setTimes(Path f,
long mtime,
long atime)
Set access time of a file.
|
abstract void |
AbstractFileSystem.setVerifyChecksum(boolean verifyChecksum)
The specification of this method matches that of
FileContext.setVerifyChecksum(boolean, Path) 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.
|
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) |
boolean |
ViewFileSystem.delete(Path f) |
boolean |
ViewFs.delete(Path f,
boolean recursive) |
boolean |
ViewFileSystem.delete(Path f,
boolean recursive) |
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) |
FsStatus |
ViewFs.getFsStatus() |
FileStatus[] |
ViewFs.listStatus(Path f) |
FileStatus[] |
ViewFileSystem.listStatus(Path f) |
RemoteIterator<FileStatus> |
ViewFs.listStatusIterator(Path f) |
void |
ViewFs.mkdir(Path dir,
FsPermission permission,
boolean createParent) |
FSDataInputStream |
ViewFs.open(Path f,
int bufferSize) |
FSDataInputStream |
ViewFileSystem.open(Path f,
int bufferSize) |
void |
ViewFs.renameInternal(Path src,
Path dst) |
Path |
ViewFs.resolvePath(Path f) |
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.setTimes(Path f,
long mtime,
long atime) |
void |
ViewFileSystem.setTimes(Path f,
long mtime,
long atime) |
void |
ViewFs.setVerifyChecksum(boolean verifyChecksum) |
Modifier and Type | Method and Description |
---|---|
void |
ZKFCProtocol.cedeActive(int millisToCede)
Request that this service yield from the active node election for the
specified time period.
|
void |
ZKFCRpcServer.cedeActive(int millisToCede) |
protected abstract void |
ZKFailoverController.checkRpcAdminAccess() |
HAServiceStatus |
HAServiceProtocol.getServiceStatus()
Return the current status of the service.
|
void |
ZKFCProtocol.gracefulFailover()
Request that this node try to become active through a graceful failover.
|
void |
ZKFCRpcServer.gracefulFailover() |
void |
HAServiceProtocol.monitorHealth()
Monitor the health of service.
|
void |
HAServiceProtocol.transitionToActive(HAServiceProtocol.StateChangeRequestInfo reqInfo)
Request service to transition to active state.
|
void |
HAServiceProtocol.transitionToStandby(HAServiceProtocol.StateChangeRequestInfo reqInfo)
Request service to transition to standby state.
|
Modifier and Type | Method and Description |
---|---|
void |
ZKFCProtocolClientSideTranslatorPB.cedeActive(int millisToCede) |
void |
ZKFCProtocolClientSideTranslatorPB.gracefulFailover() |
Modifier and Type | Method and Description |
---|---|
void |
DistributedFileSystem.createSymlink(Path target,
Path link,
boolean createParent) |
FileStatus |
DistributedFileSystem.getFileLinkStatus(Path f) |
Path |
DistributedFileSystem.getLinkTarget(Path f) |
boolean |
DistributedFileSystem.restoreFailedStorage(String arg)
enable/disable/check restoreFaileStorage
|
long |
DistributedFileSystem.rollEdits()
Rolls the edit log on the active NameNode.
|
void |
DistributedFileSystem.saveNamespace()
Save namespace image.
|
Modifier and Type | Class and Description |
---|---|
class |
SnapshotAccessControlException
Snapshot access related exception.
|
Modifier and Type | Method and Description |
---|---|
void |
ClientProtocol.abandonBlock(ExtendedBlock b,
String src,
String holder)
The client can give up on a block by calling abandonBlock().
|
LocatedBlock |
ClientProtocol.addBlock(String src,
String clientName,
ExtendedBlock previous,
DatanodeInfo[] excludeNodes,
long fileId,
String[] favoredNodes)
A client that wants to write an additional block to the
indicated filename (which must currently be open for writing)
should call addBlock().
|
LocatedBlock |
ClientProtocol.append(String src,
String clientName)
Append to the end of the file.
|
boolean |
ClientProtocol.complete(String src,
String clientName,
ExtendedBlock last,
long fileId)
The client is done writing data to the given filename, and would
like to complete it.
|
HdfsFileStatus |
ClientProtocol.create(String src,
FsPermission masked,
String clientName,
EnumSetWritable<CreateFlag> flag,
boolean createParent,
short replication,
long blockSize)
Create a new file entry in the namespace.
|
void |
ClientProtocol.createSymlink(String target,
String link,
FsPermission dirPerm,
boolean createParent)
Create symlink to a file or directory.
|
boolean |
ClientProtocol.delete(String src,
boolean recursive)
Delete the given file or directory from the file system.
|
void |
ClientProtocol.fsync(String src,
String client,
long lastBlockLength)
Write all metadata for this file into persistent storage.
|
LocatedBlock |
ClientProtocol.getAdditionalDatanode(String src,
ExtendedBlock blk,
DatanodeInfo[] existings,
DatanodeInfo[] excludes,
int numAdditionalNodes,
String clientName)
Get a datanode for an existing pipeline.
|
LocatedBlocks |
ClientProtocol.getBlockLocations(String src,
long offset,
long length)
Get locations of the blocks of the specified file within the specified range.
|
ContentSummary |
ClientProtocol.getContentSummary(String path)
Get
ContentSummary rooted at the specified directory. |
HdfsFileStatus |
ClientProtocol.getFileInfo(String src)
Get the file info for a specific file or directory.
|
HdfsFileStatus |
ClientProtocol.getFileLinkInfo(String src)
Get the file info for a specific file or directory.
|
String |
ClientProtocol.getLinkTarget(String path)
Return the target of the given symlink.
|
DirectoryListing |
ClientProtocol.getListing(String src,
byte[] startAfter,
boolean needLocation)
Get a partial listing of the indicated directory
|
boolean |
ClientProtocol.isFileClosed(String src)
Get the close status of a file
|
boolean |
ClientProtocol.mkdirs(String src,
FsPermission masked,
boolean createParent)
Create a directory (or hierarchy of directories) with the given
name and permission.
|
void |
ClientProtocol.rename2(String src,
String dst,
Options.Rename... options)
Rename src to dst.
|
void |
ClientProtocol.renewLease(String clientName)
Client programs can cause stateful changes in the NameNode
that affect other clients.
|
boolean |
ClientProtocol.restoreFailedStorage(String arg)
Enable/Disable restore failed storage.
|
long |
ClientProtocol.rollEdits()
Roll the edit log.
|
void |
ClientProtocol.saveNamespace()
Save namespace image.
|
void |
ClientProtocol.setOwner(String src,
String username,
String groupname)
Set Owner of a path (i.e.
|
void |
ClientProtocol.setPermission(String src,
FsPermission permission)
Set permissions for an existing file/directory.
|
void |
ClientProtocol.setQuota(String path,
long namespaceQuota,
long diskspaceQuota)
Set the quota for a directory.
|
boolean |
ClientProtocol.setReplication(String src,
short replication)
Set replication for an existing file.
|
void |
ClientProtocol.setTimes(String src,
long mtime,
long atime)
Sets the modification and access time of the file to the specified time.
|
Modifier and Type | Method and Description |
---|---|
void |
ClientNamenodeProtocolTranslatorPB.abandonBlock(ExtendedBlock b,
String src,
String holder) |
LocatedBlock |
ClientNamenodeProtocolTranslatorPB.addBlock(String src,
String clientName,
ExtendedBlock previous,
DatanodeInfo[] excludeNodes,
long fileId,
String[] favoredNodes) |
LocatedBlock |
ClientNamenodeProtocolTranslatorPB.append(String src,
String clientName) |
boolean |
ClientNamenodeProtocolTranslatorPB.complete(String src,
String clientName,
ExtendedBlock last,
long fileId) |
HdfsFileStatus |
ClientNamenodeProtocolTranslatorPB.create(String src,
FsPermission masked,
String clientName,
EnumSetWritable<CreateFlag> flag,
boolean createParent,
short replication,
long blockSize) |
void |
ClientNamenodeProtocolTranslatorPB.createSymlink(String target,
String link,
FsPermission dirPerm,
boolean createParent) |
boolean |
ClientNamenodeProtocolTranslatorPB.delete(String src,
boolean recursive) |
void |
ClientNamenodeProtocolTranslatorPB.fsync(String src,
String client,
long lastBlockLength) |
LocatedBlock |
ClientNamenodeProtocolTranslatorPB.getAdditionalDatanode(String src,
ExtendedBlock blk,
DatanodeInfo[] existings,
DatanodeInfo[] excludes,
int numAdditionalNodes,
String clientName) |
LocatedBlocks |
ClientNamenodeProtocolTranslatorPB.getBlockLocations(String src,
long offset,
long length) |
ContentSummary |
ClientNamenodeProtocolTranslatorPB.getContentSummary(String path) |
HdfsFileStatus |
ClientNamenodeProtocolTranslatorPB.getFileInfo(String src) |
HdfsFileStatus |
ClientNamenodeProtocolTranslatorPB.getFileLinkInfo(String src) |
String |
ClientNamenodeProtocolTranslatorPB.getLinkTarget(String path) |
DirectoryListing |
ClientNamenodeProtocolTranslatorPB.getListing(String src,
byte[] startAfter,
boolean needLocation) |
boolean |
ClientNamenodeProtocolTranslatorPB.isFileClosed(String src) |
boolean |
ClientNamenodeProtocolTranslatorPB.mkdirs(String src,
FsPermission masked,
boolean createParent) |
void |
ClientNamenodeProtocolTranslatorPB.rename2(String src,
String dst,
Options.Rename... options) |
void |
ClientNamenodeProtocolTranslatorPB.renewLease(String clientName) |
boolean |
ClientNamenodeProtocolTranslatorPB.restoreFailedStorage(String arg) |
long |
ClientNamenodeProtocolTranslatorPB.rollEdits() |
void |
ClientNamenodeProtocolTranslatorPB.saveNamespace() |
void |
ClientNamenodeProtocolTranslatorPB.setOwner(String src,
String username,
String groupname) |
void |
ClientNamenodeProtocolTranslatorPB.setPermission(String src,
FsPermission permission) |
void |
ClientNamenodeProtocolTranslatorPB.setQuota(String path,
long namespaceQuota,
long diskspaceQuota) |
boolean |
ClientNamenodeProtocolTranslatorPB.setReplication(String src,
short replication) |
void |
ClientNamenodeProtocolTranslatorPB.setTimes(String src,
long mtime,
long atime) |
Modifier and Type | Method and Description |
---|---|
void |
Namesystem.checkSuperuserPrivilege()
Check if the user has superuser privilege.
|
void |
FSNamesystem.checkSuperuserPrivilege() |
Modifier and Type | Method and Description |
---|---|
protected void |
DFSZKFailoverController.checkRpcAdminAccess() |
Modifier and Type | Class and Description |
---|---|
class |
AuthorizationException
An exception class for authorization-related issues.
|
Modifier and Type | Method and Description |
---|---|
void |
ParentQueue.submitApplication(FiCaSchedulerApp application,
String user,
String queue) |
void |
CSQueue.submitApplication(FiCaSchedulerApp application,
String user,
String queue)
Submit a new application to the queue.
|
void |
LeafQueue.submitApplication(FiCaSchedulerApp application,
String userName,
String queue) |
Copyright © 2013 Apache Software Foundation. All rights reserved.