Package | Description |
---|---|
org.apache.hadoop.ha | |
org.apache.hadoop.hdfs.protocol | |
org.apache.hadoop.hdfs.server.protocol | |
org.apache.hadoop.security | |
org.apache.hadoop.security.authorize | |
org.apache.hadoop.tools |
Command-line tools for MapReduce.
|
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.
|
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 |
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 |
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().
|
void |
ClientProtocol.allowSnapshot(String snapshotRoot)
Allow snapshot on a directory.
|
void |
ClientProtocol.cancelDelegationToken(Token<DelegationTokenIdentifier> token)
Cancel an existing delegation token.
|
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.
|
void |
ClientProtocol.disallowSnapshot(String snapshotRoot)
Disallow snapshot on a directory.
|
void |
ClientProtocol.finalizeUpgrade()
Finalize previous upgrade.
|
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. |
DataEncryptionKey |
ClientProtocol.getDataEncryptionKey() |
DatanodeInfo[] |
ClientProtocol.getDatanodeReport(HdfsConstants.DatanodeReportType type)
Get a report on the system's current datanodes.
|
Token<DelegationTokenIdentifier> |
ClientProtocol.getDelegationToken(Text renewer)
Get a valid Delegation Token.
|
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
|
long |
ClientProtocol.getPreferredBlockSize(String filename)
Get the block size for the given file.
|
FsServerDefaults |
ClientProtocol.getServerDefaults()
Get server default values for a number of configuration params.
|
SnapshotDiffReport |
ClientProtocol.getSnapshotDiffReport(String snapshotRoot,
String fromSnapshot,
String toSnapshot)
Get the difference between two snapshots, or between a snapshot and the
current tree of a directory.
|
SnapshottableDirectoryStatus[] |
ClientProtocol.getSnapshottableDirListing()
Get listing of all the snapshottable directories
|
long[] |
ClientProtocol.getStats()
Get a set of statistics about the filesystem.
|
boolean |
ClientProtocol.isFileClosed(String src)
Get the close status of a file
|
CorruptFileBlocks |
ClientProtocol.listCorruptFileBlocks(String path,
String cookie) |
void |
ClientProtocol.metaSave(String filename)
Dumps namenode data structures into specified file.
|
boolean |
ClientProtocol.mkdirs(String src,
FsPermission masked,
boolean createParent)
Create a directory (or hierarchy of directories) with the given
name and permission.
|
boolean |
ClientProtocol.recoverLease(String src,
String clientName)
Start lease recovery.
|
void |
ClientProtocol.refreshNodes()
Tells the namenode to reread the hosts and exclude files.
|
long |
ClientProtocol.renewDelegationToken(Token<DelegationTokenIdentifier> token)
Renew an existing delegation token.
|
void |
ClientProtocol.renewLease(String clientName)
Client programs can cause stateful changes in the NameNode
that affect other clients.
|
void |
ClientProtocol.reportBadBlocks(LocatedBlock[] blocks)
The client wants to report corrupted blocks (blocks with specified
locations on datanodes).
|
boolean |
ClientProtocol.restoreFailedStorage(String arg)
Enable/Disable restore failed storage.
|
long |
ClientProtocol.rollEdits()
Roll the edit log.
|
void |
ClientProtocol.setBalancerBandwidth(long bandwidth)
Tell all datanodes to use a new, non-persistent bandwidth value for
dfs.balance.bandwidthPerSec.
|
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.
|
boolean |
ClientProtocol.setSafeMode(HdfsConstants.SafeModeAction action,
boolean isChecked)
Enter, leave or get safe mode.
|
void |
ClientProtocol.setTimes(String src,
long mtime,
long atime)
Sets the modification and access time of the file to the specified time.
|
LocatedBlock |
ClientProtocol.updateBlockForPipeline(ExtendedBlock block,
String clientName)
Get a new generation stamp together with an access token for
a block under construction
This method is called only when a client needs to recover a failed
pipeline or set up a pipeline for appending to a block.
|
Modifier and Type | Method and Description |
---|---|
void |
DatanodeProtocol.blockReceivedAndDeleted(DatanodeRegistration registration,
String poolId,
StorageReceivedDeletedBlocks[] rcvdAndDeletedBlocks)
blockReceivedAndDeleted() allows the DataNode to tell the NameNode about
recently-received and -deleted block data.
|
DatanodeCommand |
DatanodeProtocol.blockReport(DatanodeRegistration registration,
String poolId,
StorageBlockReport[] reports)
blockReport() tells the NameNode about all the locally-stored blocks.
|
void |
DatanodeProtocol.commitBlockSynchronization(ExtendedBlock block,
long newgenerationstamp,
long newlength,
boolean closeFile,
boolean deleteblock,
DatanodeID[] newtargets,
String[] newtargetstorages)
Commit block synchronization in lease recovery
|
void |
DatanodeProtocol.errorReport(DatanodeRegistration registration,
int errorCode,
String msg)
errorReport() tells the NameNode about something that has gone
awry.
|
void |
NamenodeProtocol.errorReport(NamenodeRegistration registration,
int errorCode,
String msg)
Report to the active name-node an error occurred on a subordinate node.
|
ExportedBlockKeys |
NamenodeProtocol.getBlockKeys()
Get the current block keys
|
BlocksWithLocations |
NamenodeProtocol.getBlocks(DatanodeInfo datanode,
long size)
Get a list of blocks belonging to
datanode
whose total size equals size . |
RemoteEditLogManifest |
NamenodeProtocol.getEditLogManifest(long sinceTxId)
Return a structure containing details about all edit logs
available to be fetched from the NameNode.
|
long |
NamenodeProtocol.getMostRecentCheckpointTxId()
Get the transaction ID of the most recent checkpoint.
|
long |
NamenodeProtocol.getTransactionID() |
DatanodeRegistration |
DatanodeProtocol.registerDatanode(DatanodeRegistration registration)
Register Datanode.
|
NamenodeRegistration |
NamenodeProtocol.registerSubordinateNamenode(NamenodeRegistration registration)
Register a subordinate name-node like backup node.
|
void |
DatanodeProtocol.reportBadBlocks(LocatedBlock[] blocks)
|
CheckpointSignature |
NamenodeProtocol.rollEditLog()
Closes the current edit log and opens a new one.
|
HeartbeatResponse |
DatanodeProtocol.sendHeartbeat(DatanodeRegistration registration,
StorageReport[] reports,
int xmitsInProgress,
int xceiverCount,
int failedVolumes)
sendHeartbeat() tells the NameNode that the DataNode is still
alive and well.
|
NamespaceInfo |
DatanodeProtocol.versionRequest() |
NamespaceInfo |
NamenodeProtocol.versionRequest()
Request name-node version and storage information.
|
Modifier and Type | Method and Description |
---|---|
void |
RefreshUserMappingsProtocol.refreshSuperUserGroupsConfiguration()
Refresh superuser proxy group list
|
void |
RefreshUserMappingsProtocol.refreshUserToGroupsMappings()
Refresh user to group mappings.
|
Modifier and Type | Method and Description |
---|---|
void |
RefreshAuthorizationPolicyProtocol.refreshServiceAcl()
Refresh the service-level authorization policy in-effect.
|
Modifier and Type | Method and Description |
---|---|
String[] |
GetUserMappingsProtocol.getGroupsForUser(String user)
Get the groups which are mapped to the given user.
|
Copyright © 2013 Apache Software Foundation. All rights reserved.