Package org.apache.hadoop.hdfs.protocolPB

Class RouterClientProtocolTranslatorPB

java.lang.Object

org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

org.apache.hadoop.hdfs.protocolPB.RouterClientProtocolTranslatorPB

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.hdfs.protocol.ClientProtocol, org.apache.hadoop.ipc.ProtocolMetaInterface, org.apache.hadoop.ipc.ProtocolTranslator

@Private
@Stable
public class RouterClientProtocolTranslatorPB
extends org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

This class forwards NN's ClientProtocol calls as RPC calls to the NN server while translating from the parameter types used in ClientProtocol to the new PB types.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB.BatchedCacheEntries, org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB.BatchedCachePoolEntries

Field Summary

Fields inherited from class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

VOID_FINALIZE_UPGRADE_REQUEST, VOID_GET_DATA_ENCRYPTIONKEY_REQUEST, VOID_GET_EC_CODEC_REQUEST, VOID_GET_EC_POLICIES_REQUEST, VOID_GET_FS_ECBLOCKGROUP_STATS_REQUEST, VOID_GET_FS_REPLICATED_BLOCK_STATS_REQUEST, VOID_GET_FSSTATUS_REQUEST, VOID_GET_SERVER_DEFAULT_REQUEST, VOID_GET_STORAGE_POLICIES_REQUEST, VOID_REFRESH_NODES_REQUEST, VOID_ROLLEDITS_REQUEST, VOID_UPGRADE_STATUS_REQUEST

Fields inherited from interface org.apache.hadoop.hdfs.protocol.ClientProtocol

GET_STATS_BYTES_IN_FUTURE_BLOCKS_IDX, GET_STATS_CAPACITY_IDX, GET_STATS_CORRUPT_BLOCKS_IDX, GET_STATS_LOW_REDUNDANCY_IDX, GET_STATS_MISSING_BLOCKS_IDX, GET_STATS_MISSING_REPL_ONE_BLOCKS_IDX, GET_STATS_PENDING_DELETION_BLOCKS_IDX, GET_STATS_REMAINING_IDX, GET_STATS_UNDER_REPLICATED_IDX, GET_STATS_USED_IDX, STATS_ARRAY_LENGTH, versionID

Constructor Summary

Constructors

Constructor	Description
RouterClientProtocolTranslatorPB(org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolPB proxy)

Method Summary

Modifier and Type	Method	Description
void	abandonBlock(org.apache.hadoop.hdfs.protocol.ExtendedBlock b, long fileId, String src, String holder)
org.apache.hadoop.hdfs.protocol.LocatedBlock	addBlock(String src, String clientName, org.apache.hadoop.hdfs.protocol.ExtendedBlock previous, org.apache.hadoop.hdfs.protocol.DatanodeInfo[] excludeNodes, long fileId, String[] favoredNodes, EnumSet<org.apache.hadoop.hdfs.AddBlockFlag> addBlockFlags)
long	addCacheDirective(org.apache.hadoop.hdfs.protocol.CacheDirectiveInfo directive, EnumSet<org.apache.hadoop.fs.CacheFlag> flags)
void	addCachePool(org.apache.hadoop.hdfs.protocol.CachePoolInfo info)
org.apache.hadoop.hdfs.protocol.AddErasureCodingPolicyResponse[]	addErasureCodingPolicies(org.apache.hadoop.hdfs.protocol.ErasureCodingPolicy[] policies)
void	allowSnapshot(String snapshotRoot)
org.apache.hadoop.hdfs.protocol.LastBlockWithStatus	append(String src, String clientName, org.apache.hadoop.io.EnumSetWritable<org.apache.hadoop.fs.CreateFlag> flag)
void	cancelDelegationToken(org.apache.hadoop.security.token.Token<org.apache.hadoop.hdfs.security.token.delegation.DelegationTokenIdentifier> token)
void	checkAccess(String path, org.apache.hadoop.fs.permission.FsAction mode)
void	close()
boolean	complete(String src, String clientName, org.apache.hadoop.hdfs.protocol.ExtendedBlock last, long fileId)
void	concat(String trg, String[] srcs)
org.apache.hadoop.hdfs.protocol.HdfsFileStatus	create(String src, org.apache.hadoop.fs.permission.FsPermission masked, String clientName, org.apache.hadoop.io.EnumSetWritable<org.apache.hadoop.fs.CreateFlag> flag, boolean createParent, short replication, long blockSize, org.apache.hadoop.crypto.CryptoProtocolVersion[] supportedVersions, String ecPolicyName, String storagePolicy)
void	createEncryptionZone(String src, String keyName)
String	createSnapshot(String snapshotRoot, String snapshotName)
void	createSymlink(String target, String link, org.apache.hadoop.fs.permission.FsPermission dirPerm, boolean createParent)
boolean	delete(String src, boolean recursive)
void	deleteSnapshot(String snapshotRoot, String snapshotName)
void	disableErasureCodingPolicy(String ecPolicyName)
void	disallowSnapshot(String snapshotRoot)
void	enableErasureCodingPolicy(String ecPolicyName)
void	finalizeUpgrade()
void	fsync(String src, long fileId, String client, long lastBlockLength)
org.apache.hadoop.fs.permission.AclStatus	getAclStatus(String src)
org.apache.hadoop.hdfs.protocol.LocatedBlock	getAdditionalDatanode(String src, long fileId, org.apache.hadoop.hdfs.protocol.ExtendedBlock blk, org.apache.hadoop.hdfs.protocol.DatanodeInfo[] existings, String[] existingStorageIDs, org.apache.hadoop.hdfs.protocol.DatanodeInfo[] excludes, int numAdditionalNodes, String clientName)
org.apache.hadoop.hdfs.protocol.BatchedDirectoryListing	getBatchedListing(String[] srcs, byte[] startAfter, boolean needLocation)
org.apache.hadoop.hdfs.protocol.LocatedBlocks	getBlockLocations(String src, long offset, long length)
org.apache.hadoop.fs.ContentSummary	getContentSummary(String path)
long	getCurrentEditLogTxid()
org.apache.hadoop.hdfs.security.token.block.DataEncryptionKey	getDataEncryptionKey()
org.apache.hadoop.hdfs.protocol.DatanodeInfo[]	getDatanodeReport(org.apache.hadoop.hdfs.protocol.HdfsConstants.DatanodeReportType type)
org.apache.hadoop.hdfs.server.protocol.DatanodeStorageReport[]	getDatanodeStorageReport(org.apache.hadoop.hdfs.protocol.HdfsConstants.DatanodeReportType type)
org.apache.hadoop.security.token.Token<org.apache.hadoop.hdfs.security.token.delegation.DelegationTokenIdentifier>	getDelegationToken(org.apache.hadoop.io.Text renewer)
org.apache.hadoop.hdfs.protocol.ECBlockGroupStats	getECBlockGroupStats()
org.apache.hadoop.hdfs.protocol.ECTopologyVerifierResult	getECTopologyResultForPolicies(String... policyNames)
org.apache.hadoop.hdfs.inotify.EventBatchList	getEditsFromTxid(long txid)
org.apache.hadoop.fs.Path	getEnclosingRoot(String filename)
Map<String,String>	getErasureCodingCodecs()
org.apache.hadoop.hdfs.protocol.ErasureCodingPolicyInfo[]	getErasureCodingPolicies()
org.apache.hadoop.hdfs.protocol.ErasureCodingPolicy	getErasureCodingPolicy(String src)
org.apache.hadoop.hdfs.protocol.EncryptionZone	getEZForPath(String src)
org.apache.hadoop.hdfs.protocol.HdfsFileStatus	getFileInfo(String src)
org.apache.hadoop.hdfs.protocol.HdfsFileStatus	getFileLinkInfo(String src)
org.apache.hadoop.ha.HAServiceProtocol.HAServiceState	getHAServiceState()
String	getLinkTarget(String path)
org.apache.hadoop.hdfs.protocol.DirectoryListing	getListing(String src, byte[] startAfter, boolean needLocation)
org.apache.hadoop.hdfs.protocol.HdfsLocatedFileStatus	getLocatedFileInfo(String src, boolean needBlockToken)
long	getPreferredBlockSize(String filename)
org.apache.hadoop.fs.QuotaUsage	getQuotaUsage(String path)
org.apache.hadoop.hdfs.protocol.ReplicatedBlockStats	getReplicatedBlockStats()
org.apache.hadoop.fs.FsServerDefaults	getServerDefaults()
org.apache.hadoop.hdfs.protocol.DatanodeInfo[]	getSlowDatanodeReport()
org.apache.hadoop.hdfs.protocol.SnapshotDiffReport	getSnapshotDiffReport(String snapshotRoot, String fromSnapshot, String toSnapshot)
org.apache.hadoop.hdfs.protocol.SnapshotDiffReportListing	getSnapshotDiffReportListing(String snapshotRoot, String fromSnapshot, String toSnapshot, byte[] startPath, int index)
org.apache.hadoop.hdfs.protocol.SnapshotStatus[]	getSnapshotListing(String path)
org.apache.hadoop.hdfs.protocol.SnapshottableDirectoryStatus[]	getSnapshottableDirListing()
long[]	getStats()
org.apache.hadoop.hdfs.protocol.BlockStoragePolicy[]	getStoragePolicies()
org.apache.hadoop.hdfs.protocol.BlockStoragePolicy	getStoragePolicy(String path)
List<org.apache.hadoop.fs.XAttr>	getXAttrs(String src, List<org.apache.hadoop.fs.XAttr> xAttrs)
boolean	isFileClosed(String src)
org.apache.hadoop.fs.BatchedRemoteIterator.BatchedEntries<org.apache.hadoop.hdfs.protocol.CacheDirectiveEntry>	listCacheDirectives(long prevId, org.apache.hadoop.hdfs.protocol.CacheDirectiveInfo filter)
org.apache.hadoop.fs.BatchedRemoteIterator.BatchedEntries<org.apache.hadoop.hdfs.protocol.CachePoolEntry>	listCachePools(String prevKey)
org.apache.hadoop.hdfs.protocol.CorruptFileBlocks	listCorruptFileBlocks(String path, String cookie)
org.apache.hadoop.fs.BatchedRemoteIterator.BatchedEntries<org.apache.hadoop.hdfs.protocol.EncryptionZone>	listEncryptionZones(long id)
org.apache.hadoop.fs.BatchedRemoteIterator.BatchedEntries<org.apache.hadoop.hdfs.protocol.OpenFileEntry>	listOpenFiles(long prevId, EnumSet<org.apache.hadoop.hdfs.protocol.OpenFilesIterator.OpenFilesType> openFilesTypes, String path)
org.apache.hadoop.fs.BatchedRemoteIterator.BatchedEntries<org.apache.hadoop.hdfs.protocol.ZoneReencryptionStatus>	listReencryptionStatus(long id)
List<org.apache.hadoop.fs.XAttr>	listXAttrs(String src)
void	metaSave(String filename)
boolean	mkdirs(String src, org.apache.hadoop.fs.permission.FsPermission masked, boolean createParent)
void	modifyAclEntries(String src, List<org.apache.hadoop.fs.permission.AclEntry> aclSpec)
void	modifyCacheDirective(org.apache.hadoop.hdfs.protocol.CacheDirectiveInfo directive, EnumSet<org.apache.hadoop.fs.CacheFlag> flags)
void	modifyCachePool(org.apache.hadoop.hdfs.protocol.CachePoolInfo req)
void	msync()
boolean	recoverLease(String src, String clientName)
void	reencryptEncryptionZone(String zone, org.apache.hadoop.hdfs.protocol.HdfsConstants.ReencryptAction action)
void	refreshNodes()
void	removeAcl(String src)
void	removeAclEntries(String src, List<org.apache.hadoop.fs.permission.AclEntry> aclSpec)
void	removeCacheDirective(long id)
void	removeCachePool(String cachePoolName)
void	removeDefaultAcl(String src)
void	removeErasureCodingPolicy(String ecPolicyName)
void	removeXAttr(String src, org.apache.hadoop.fs.XAttr xAttr)
boolean	rename(String src, String dst)
void	rename2(String src, String dst, org.apache.hadoop.fs.Options.Rename... options)
void	renameSnapshot(String snapshotRoot, String snapshotOldName, String snapshotNewName)
long	renewDelegationToken(org.apache.hadoop.security.token.Token<org.apache.hadoop.hdfs.security.token.delegation.DelegationTokenIdentifier> token)
void	renewLease(String clientName, List<String> namespaces)
void	reportBadBlocks(org.apache.hadoop.hdfs.protocol.LocatedBlock[] blocks)
boolean	restoreFailedStorage(String arg)
long	rollEdits()
org.apache.hadoop.hdfs.protocol.RollingUpgradeInfo	rollingUpgrade(org.apache.hadoop.hdfs.protocol.HdfsConstants.RollingUpgradeAction action)
void	satisfyStoragePolicy(String src)
boolean	saveNamespace(long timeWindow, long txGap)
void	setAcl(String src, List<org.apache.hadoop.fs.permission.AclEntry> aclSpec)
void	setBalancerBandwidth(long bandwidth)
void	setErasureCodingPolicy(String src, String ecPolicyName)
void	setOwner(String src, String username, String groupname)
void	setPermission(String src, org.apache.hadoop.fs.permission.FsPermission permission)
void	setQuota(String path, long namespaceQuota, long storagespaceQuota, org.apache.hadoop.fs.StorageType type)
boolean	setReplication(String src, short replication)
boolean	setSafeMode(org.apache.hadoop.hdfs.protocol.HdfsConstants.SafeModeAction action, boolean isChecked)
void	setStoragePolicy(String src, String policyName)
void	setTimes(String src, long mtime, long atime)
void	setXAttr(String src, org.apache.hadoop.fs.XAttr xAttr, EnumSet<org.apache.hadoop.fs.XAttrSetFlag> flag)
boolean	truncate(String src, long newLength, String clientName)
void	unsetErasureCodingPolicy(String src)
void	unsetStoragePolicy(String src)
org.apache.hadoop.hdfs.protocol.LocatedBlock	updateBlockForPipeline(org.apache.hadoop.hdfs.protocol.ExtendedBlock block, String clientName)
void	updatePipeline(String clientName, org.apache.hadoop.hdfs.protocol.ExtendedBlock oldBlock, org.apache.hadoop.hdfs.protocol.ExtendedBlock newBlock, org.apache.hadoop.hdfs.protocol.DatanodeID[] newNodes, String[] storageIDs)
boolean	upgradeStatus()

Methods inherited from class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

getUnderlyingProxyObject, isMethodSupported, listOpenFiles

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

RouterClientProtocolTranslatorPB

public RouterClientProtocolTranslatorPB(org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolPB proxy)

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

getBlockLocations

public org.apache.hadoop.hdfs.protocol.LocatedBlocks getBlockLocations(String src,
 long offset,
 long length)
                                                                throws IOException

Specified by:

getBlockLocations in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getBlockLocations in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getServerDefaults

public org.apache.hadoop.fs.FsServerDefaults getServerDefaults()
                                                        throws IOException

Specified by:

getServerDefaults in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getServerDefaults in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

create

public org.apache.hadoop.hdfs.protocol.HdfsFileStatus create(String src,
 org.apache.hadoop.fs.permission.FsPermission masked,
 String clientName,
 org.apache.hadoop.io.EnumSetWritable<org.apache.hadoop.fs.CreateFlag> flag,
 boolean createParent,
 short replication,
 long blockSize,
 org.apache.hadoop.crypto.CryptoProtocolVersion[] supportedVersions,
 String ecPolicyName,
 String storagePolicy)
                                                      throws IOException

Specified by:

create in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

create in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

truncate

public boolean truncate(String src,
 long newLength,
 String clientName)
                 throws IOException

Specified by:

truncate in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

truncate in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

append

public org.apache.hadoop.hdfs.protocol.LastBlockWithStatus append(String src,
 String clientName,
 org.apache.hadoop.io.EnumSetWritable<org.apache.hadoop.fs.CreateFlag> flag)
                                                           throws IOException

Specified by:

append in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

append in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

setReplication

public boolean setReplication(String src,
 short replication)
                       throws IOException

Specified by:

setReplication in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

setReplication in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

setPermission

public void setPermission(String src,
 org.apache.hadoop.fs.permission.FsPermission permission)
                   throws IOException

Specified by:

setPermission in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

setPermission in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

setOwner

public void setOwner(String src,
 String username,
 String groupname)
              throws IOException

Specified by:

setOwner in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

setOwner in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

abandonBlock

public void abandonBlock(org.apache.hadoop.hdfs.protocol.ExtendedBlock b,
 long fileId,
 String src,
 String holder)
                  throws IOException

Specified by:

abandonBlock in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

abandonBlock in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

addBlock

public org.apache.hadoop.hdfs.protocol.LocatedBlock addBlock(String src,
 String clientName,
 org.apache.hadoop.hdfs.protocol.ExtendedBlock previous,
 org.apache.hadoop.hdfs.protocol.DatanodeInfo[] excludeNodes,
 long fileId,
 String[] favoredNodes,
 EnumSet<org.apache.hadoop.hdfs.AddBlockFlag> addBlockFlags)
                                                      throws IOException

Specified by:

addBlock in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

addBlock in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getAdditionalDatanode

public org.apache.hadoop.hdfs.protocol.LocatedBlock getAdditionalDatanode(String src,
 long fileId,
 org.apache.hadoop.hdfs.protocol.ExtendedBlock blk,
 org.apache.hadoop.hdfs.protocol.DatanodeInfo[] existings,
 String[] existingStorageIDs,
 org.apache.hadoop.hdfs.protocol.DatanodeInfo[] excludes,
 int numAdditionalNodes,
 String clientName)
                                                                   throws IOException

Specified by:

getAdditionalDatanode in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getAdditionalDatanode in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

complete

public boolean complete(String src,
 String clientName,
 org.apache.hadoop.hdfs.protocol.ExtendedBlock last,
 long fileId)
                 throws IOException

Specified by:

complete in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

complete in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

reportBadBlocks

public void reportBadBlocks(org.apache.hadoop.hdfs.protocol.LocatedBlock[] blocks)
                     throws IOException

Specified by:

reportBadBlocks in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

reportBadBlocks in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

rename

public boolean rename(String src,
 String dst)
               throws IOException

Specified by:

rename in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

rename in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

rename2

public void rename2(String src,
 String dst,
 org.apache.hadoop.fs.Options.Rename... options)
             throws IOException

Specified by:

rename2 in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

rename2 in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

concat

public void concat(String trg,
 String[] srcs)
            throws IOException

Specified by:

concat in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

concat in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

delete

public boolean delete(String src,
 boolean recursive)
               throws IOException

Specified by:

delete in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

delete in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

mkdirs

public boolean mkdirs(String src,
 org.apache.hadoop.fs.permission.FsPermission masked,
 boolean createParent)
               throws IOException

Specified by:

mkdirs in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

mkdirs in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getListing

public org.apache.hadoop.hdfs.protocol.DirectoryListing getListing(String src,
 byte[] startAfter,
 boolean needLocation)
                                                            throws IOException

Specified by:

getListing in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getListing in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getBatchedListing

public org.apache.hadoop.hdfs.protocol.BatchedDirectoryListing getBatchedListing(String[] srcs,
 byte[] startAfter,
 boolean needLocation)
                                                                          throws IOException

Specified by:

getBatchedListing in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getBatchedListing in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

renewLease

public void renewLease(String clientName,
 List<String> namespaces)
                throws IOException

Specified by:

renewLease in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

renewLease in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

recoverLease

public boolean recoverLease(String src,
 String clientName)
                     throws IOException

Specified by:

recoverLease in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

recoverLease in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getStats

public long[] getStats()
                throws IOException

Specified by:

getStats in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getStats in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getReplicatedBlockStats

public org.apache.hadoop.hdfs.protocol.ReplicatedBlockStats getReplicatedBlockStats()
                                                                             throws IOException

Specified by:

getReplicatedBlockStats in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getReplicatedBlockStats in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getECBlockGroupStats

public org.apache.hadoop.hdfs.protocol.ECBlockGroupStats getECBlockGroupStats()
                                                                       throws IOException

Specified by:

getECBlockGroupStats in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getECBlockGroupStats in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getDatanodeReport

public org.apache.hadoop.hdfs.protocol.DatanodeInfo[] getDatanodeReport(org.apache.hadoop.hdfs.protocol.HdfsConstants.DatanodeReportType type)
                                                                 throws IOException

Specified by:

getDatanodeReport in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getDatanodeReport in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getDatanodeStorageReport

public org.apache.hadoop.hdfs.server.protocol.DatanodeStorageReport[] getDatanodeStorageReport(org.apache.hadoop.hdfs.protocol.HdfsConstants.DatanodeReportType type)
                                                                                        throws IOException

Specified by:

getDatanodeStorageReport in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getDatanodeStorageReport in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getPreferredBlockSize

public long getPreferredBlockSize(String filename)
                           throws IOException

Specified by:

getPreferredBlockSize in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getPreferredBlockSize in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

setSafeMode

public boolean setSafeMode(org.apache.hadoop.hdfs.protocol.HdfsConstants.SafeModeAction action,
 boolean isChecked)
                    throws IOException

Specified by:

setSafeMode in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

setSafeMode in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

saveNamespace

public boolean saveNamespace(long timeWindow,
 long txGap)
                      throws IOException

Specified by:

saveNamespace in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

saveNamespace in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

rollEdits

public long rollEdits()
               throws IOException

Specified by:

rollEdits in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

rollEdits in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

restoreFailedStorage

public boolean restoreFailedStorage(String arg)
                             throws IOException

Specified by:

restoreFailedStorage in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

restoreFailedStorage in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

refreshNodes

public void refreshNodes()
                  throws IOException

Specified by:

refreshNodes in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

refreshNodes in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

finalizeUpgrade

public void finalizeUpgrade()
                     throws IOException

Specified by:

finalizeUpgrade in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

finalizeUpgrade in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

upgradeStatus

public boolean upgradeStatus()
                      throws IOException

Specified by:

upgradeStatus in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

upgradeStatus in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

rollingUpgrade

public org.apache.hadoop.hdfs.protocol.RollingUpgradeInfo rollingUpgrade(org.apache.hadoop.hdfs.protocol.HdfsConstants.RollingUpgradeAction action)
                                                                  throws IOException

Specified by:

rollingUpgrade in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

rollingUpgrade in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

listCorruptFileBlocks

public org.apache.hadoop.hdfs.protocol.CorruptFileBlocks listCorruptFileBlocks(String path,
 String cookie)
                                                                        throws IOException

Specified by:

listCorruptFileBlocks in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

listCorruptFileBlocks in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

metaSave

public void metaSave(String filename)
              throws IOException

Specified by:

metaSave in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

metaSave in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getFileInfo

public org.apache.hadoop.hdfs.protocol.HdfsFileStatus getFileInfo(String src)
                                                           throws IOException

Specified by:

getFileInfo in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getFileInfo in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getLocatedFileInfo

public org.apache.hadoop.hdfs.protocol.HdfsLocatedFileStatus getLocatedFileInfo(String src,
 boolean needBlockToken)
                                                                         throws IOException

Specified by:

getLocatedFileInfo in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getLocatedFileInfo in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getFileLinkInfo

public org.apache.hadoop.hdfs.protocol.HdfsFileStatus getFileLinkInfo(String src)
                                                               throws IOException

Specified by:

getFileLinkInfo in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getFileLinkInfo in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getContentSummary

public org.apache.hadoop.fs.ContentSummary getContentSummary(String path)
                                                      throws IOException

Specified by:

getContentSummary in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getContentSummary in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

setQuota

public void setQuota(String path,
 long namespaceQuota,
 long storagespaceQuota,
 org.apache.hadoop.fs.StorageType type)
              throws IOException

Specified by:

setQuota in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

setQuota in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

fsync

public void fsync(String src,
 long fileId,
 String client,
 long lastBlockLength)
           throws IOException

Specified by:

fsync in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

fsync in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

setTimes

public void setTimes(String src,
 long mtime,
 long atime)
              throws IOException

Specified by:

setTimes in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

setTimes in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

createSymlink

public void createSymlink(String target,
 String link,
 org.apache.hadoop.fs.permission.FsPermission dirPerm,
 boolean createParent)
                   throws IOException

Specified by:

createSymlink in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

createSymlink in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getLinkTarget

public String getLinkTarget(String path)
                     throws IOException

Specified by:

getLinkTarget in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getLinkTarget in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

updateBlockForPipeline

public org.apache.hadoop.hdfs.protocol.LocatedBlock updateBlockForPipeline(org.apache.hadoop.hdfs.protocol.ExtendedBlock block,
 String clientName)
                                                                    throws IOException

Specified by:

updateBlockForPipeline in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

updateBlockForPipeline in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

updatePipeline

public void updatePipeline(String clientName,
 org.apache.hadoop.hdfs.protocol.ExtendedBlock oldBlock,
 org.apache.hadoop.hdfs.protocol.ExtendedBlock newBlock,
 org.apache.hadoop.hdfs.protocol.DatanodeID[] newNodes,
 String[] storageIDs)
                    throws IOException

Specified by:

updatePipeline in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

updatePipeline in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getDelegationToken

public org.apache.hadoop.security.token.Token<org.apache.hadoop.hdfs.security.token.delegation.DelegationTokenIdentifier> getDelegationToken(org.apache.hadoop.io.Text renewer)
                                                                                                                                      throws IOException

Specified by:

getDelegationToken in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getDelegationToken in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

renewDelegationToken

public long renewDelegationToken(org.apache.hadoop.security.token.Token<org.apache.hadoop.hdfs.security.token.delegation.DelegationTokenIdentifier> token)
                          throws IOException

Specified by:

renewDelegationToken in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

renewDelegationToken in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

cancelDelegationToken

public void cancelDelegationToken(org.apache.hadoop.security.token.Token<org.apache.hadoop.hdfs.security.token.delegation.DelegationTokenIdentifier> token)
                           throws IOException

Specified by:

cancelDelegationToken in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

cancelDelegationToken in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

setBalancerBandwidth

public void setBalancerBandwidth(long bandwidth)
                          throws IOException

Specified by:

setBalancerBandwidth in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

setBalancerBandwidth in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getDataEncryptionKey

public org.apache.hadoop.hdfs.security.token.block.DataEncryptionKey getDataEncryptionKey()
                                                                                   throws IOException

Specified by:

getDataEncryptionKey in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getDataEncryptionKey in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

isFileClosed

public boolean isFileClosed(String src)
                     throws IOException

Specified by:

isFileClosed in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

isFileClosed in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

createSnapshot

public String createSnapshot(String snapshotRoot,
 String snapshotName)
                      throws IOException

Specified by:

createSnapshot in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

createSnapshot in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

deleteSnapshot

public void deleteSnapshot(String snapshotRoot,
 String snapshotName)
                    throws IOException

Specified by:

deleteSnapshot in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

deleteSnapshot in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

allowSnapshot

public void allowSnapshot(String snapshotRoot)
                   throws IOException

Specified by:

allowSnapshot in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

allowSnapshot in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

disallowSnapshot

public void disallowSnapshot(String snapshotRoot)
                      throws IOException

Specified by:

disallowSnapshot in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

disallowSnapshot in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

renameSnapshot

public void renameSnapshot(String snapshotRoot,
 String snapshotOldName,
 String snapshotNewName)
                    throws IOException

Specified by:

renameSnapshot in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

renameSnapshot in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getSnapshottableDirListing

public org.apache.hadoop.hdfs.protocol.SnapshottableDirectoryStatus[] getSnapshottableDirListing()
                                                                                          throws IOException

Specified by:

getSnapshottableDirListing in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getSnapshottableDirListing in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getSnapshotListing

public org.apache.hadoop.hdfs.protocol.SnapshotStatus[] getSnapshotListing(String path)
                                                                    throws IOException

Specified by:

getSnapshotListing in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getSnapshotListing in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getSnapshotDiffReport

public org.apache.hadoop.hdfs.protocol.SnapshotDiffReport getSnapshotDiffReport(String snapshotRoot,
 String fromSnapshot,
 String toSnapshot)
                                                                         throws IOException

Specified by:

getSnapshotDiffReport in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getSnapshotDiffReport in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getSnapshotDiffReportListing

public org.apache.hadoop.hdfs.protocol.SnapshotDiffReportListing getSnapshotDiffReportListing(String snapshotRoot,
 String fromSnapshot,
 String toSnapshot,
 byte[] startPath,
 int index)
                                                                                       throws IOException

Specified by:

getSnapshotDiffReportListing in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getSnapshotDiffReportListing in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

addCacheDirective

public long addCacheDirective(org.apache.hadoop.hdfs.protocol.CacheDirectiveInfo directive,
 EnumSet<org.apache.hadoop.fs.CacheFlag> flags)
                       throws IOException

Specified by:

addCacheDirective in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

addCacheDirective in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

modifyCacheDirective

public void modifyCacheDirective(org.apache.hadoop.hdfs.protocol.CacheDirectiveInfo directive,
 EnumSet<org.apache.hadoop.fs.CacheFlag> flags)
                          throws IOException

Specified by:

modifyCacheDirective in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

modifyCacheDirective in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

removeCacheDirective

public void removeCacheDirective(long id)
                          throws IOException

Specified by:

removeCacheDirective in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

removeCacheDirective in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

listCacheDirectives

public org.apache.hadoop.fs.BatchedRemoteIterator.BatchedEntries<org.apache.hadoop.hdfs.protocol.CacheDirectiveEntry> listCacheDirectives(long prevId,
 org.apache.hadoop.hdfs.protocol.CacheDirectiveInfo filter)
                                                                                                                                   throws IOException

Specified by:

listCacheDirectives in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

listCacheDirectives in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

addCachePool

public void addCachePool(org.apache.hadoop.hdfs.protocol.CachePoolInfo info)
                  throws IOException

Specified by:

addCachePool in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

addCachePool in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

modifyCachePool

public void modifyCachePool(org.apache.hadoop.hdfs.protocol.CachePoolInfo req)
                     throws IOException

Specified by:

modifyCachePool in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

modifyCachePool in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

removeCachePool

public void removeCachePool(String cachePoolName)
                     throws IOException

Specified by:

removeCachePool in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

removeCachePool in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

listCachePools

public org.apache.hadoop.fs.BatchedRemoteIterator.BatchedEntries<org.apache.hadoop.hdfs.protocol.CachePoolEntry> listCachePools(String prevKey)
                                                                                                                         throws IOException

Specified by:

listCachePools in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

listCachePools in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

modifyAclEntries

public void modifyAclEntries(String src,
 List<org.apache.hadoop.fs.permission.AclEntry> aclSpec)
                      throws IOException

Specified by:

modifyAclEntries in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

modifyAclEntries in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

removeAclEntries

public void removeAclEntries(String src,
 List<org.apache.hadoop.fs.permission.AclEntry> aclSpec)
                      throws IOException

Specified by:

removeAclEntries in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

removeAclEntries in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

removeDefaultAcl

public void removeDefaultAcl(String src)
                      throws IOException

Specified by:

removeDefaultAcl in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

removeDefaultAcl in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

removeAcl

public void removeAcl(String src)
               throws IOException

Specified by:

removeAcl in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

removeAcl in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

setAcl

public void setAcl(String src,
 List<org.apache.hadoop.fs.permission.AclEntry> aclSpec)
            throws IOException

Specified by:

setAcl in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

setAcl in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getAclStatus

public org.apache.hadoop.fs.permission.AclStatus getAclStatus(String src)
                                                       throws IOException

Specified by:

getAclStatus in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getAclStatus in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

createEncryptionZone

public void createEncryptionZone(String src,
 String keyName)
                          throws IOException

Specified by:

createEncryptionZone in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

createEncryptionZone in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getEZForPath

public org.apache.hadoop.hdfs.protocol.EncryptionZone getEZForPath(String src)
                                                            throws IOException

Specified by:

getEZForPath in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getEZForPath in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

listEncryptionZones

public org.apache.hadoop.fs.BatchedRemoteIterator.BatchedEntries<org.apache.hadoop.hdfs.protocol.EncryptionZone> listEncryptionZones(long id)
                                                                                                                              throws IOException

Specified by:

listEncryptionZones in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

listEncryptionZones in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

setErasureCodingPolicy

public void setErasureCodingPolicy(String src,
 String ecPolicyName)
                            throws IOException

Specified by:

setErasureCodingPolicy in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

setErasureCodingPolicy in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

unsetErasureCodingPolicy

public void unsetErasureCodingPolicy(String src)
                              throws IOException

Specified by:

unsetErasureCodingPolicy in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

unsetErasureCodingPolicy in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getECTopologyResultForPolicies

public org.apache.hadoop.hdfs.protocol.ECTopologyVerifierResult getECTopologyResultForPolicies(String... policyNames)
                                                                                        throws IOException

Specified by:

getECTopologyResultForPolicies in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getECTopologyResultForPolicies in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

reencryptEncryptionZone

public void reencryptEncryptionZone(String zone,
 org.apache.hadoop.hdfs.protocol.HdfsConstants.ReencryptAction action)
                             throws IOException

Specified by:

reencryptEncryptionZone in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

reencryptEncryptionZone in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

listReencryptionStatus

public org.apache.hadoop.fs.BatchedRemoteIterator.BatchedEntries<org.apache.hadoop.hdfs.protocol.ZoneReencryptionStatus> listReencryptionStatus(long id)
                                                                                                                                         throws IOException

Specified by:

listReencryptionStatus in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

listReencryptionStatus in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

setXAttr

public void setXAttr(String src,
 org.apache.hadoop.fs.XAttr xAttr,
 EnumSet<org.apache.hadoop.fs.XAttrSetFlag> flag)
              throws IOException

Specified by:

setXAttr in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

setXAttr in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getXAttrs

public List<org.apache.hadoop.fs.XAttr> getXAttrs(String src,
 List<org.apache.hadoop.fs.XAttr> xAttrs)
                                           throws IOException

Specified by:

getXAttrs in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getXAttrs in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

listXAttrs

public List<org.apache.hadoop.fs.XAttr> listXAttrs(String src)
                                            throws IOException

Specified by:

listXAttrs in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

listXAttrs in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

removeXAttr

public void removeXAttr(String src,
 org.apache.hadoop.fs.XAttr xAttr)
                 throws IOException

Specified by:

removeXAttr in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

removeXAttr in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

checkAccess

public void checkAccess(String path,
 org.apache.hadoop.fs.permission.FsAction mode)
                 throws IOException

Specified by:

checkAccess in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

checkAccess in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

setStoragePolicy

public void setStoragePolicy(String src,
 String policyName)
                      throws IOException

Specified by:

setStoragePolicy in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

setStoragePolicy in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

unsetStoragePolicy

public void unsetStoragePolicy(String src)
                        throws IOException

Specified by:

unsetStoragePolicy in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

unsetStoragePolicy in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getStoragePolicy

public org.apache.hadoop.hdfs.protocol.BlockStoragePolicy getStoragePolicy(String path)
                                                                    throws IOException

Specified by:

getStoragePolicy in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getStoragePolicy in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getStoragePolicies

public org.apache.hadoop.hdfs.protocol.BlockStoragePolicy[] getStoragePolicies()
                                                                        throws IOException

Specified by:

getStoragePolicies in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getStoragePolicies in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getCurrentEditLogTxid

public long getCurrentEditLogTxid()
                           throws IOException

Specified by:

getCurrentEditLogTxid in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getCurrentEditLogTxid in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getEditsFromTxid

public org.apache.hadoop.hdfs.inotify.EventBatchList getEditsFromTxid(long txid)
                                                               throws IOException

Specified by:

getEditsFromTxid in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getEditsFromTxid in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

addErasureCodingPolicies

public org.apache.hadoop.hdfs.protocol.AddErasureCodingPolicyResponse[] addErasureCodingPolicies(org.apache.hadoop.hdfs.protocol.ErasureCodingPolicy[] policies)
                                                                                          throws IOException

Specified by:

addErasureCodingPolicies in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

addErasureCodingPolicies in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

removeErasureCodingPolicy

public void removeErasureCodingPolicy(String ecPolicyName)
                               throws IOException

Specified by:

removeErasureCodingPolicy in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

removeErasureCodingPolicy in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

enableErasureCodingPolicy

public void enableErasureCodingPolicy(String ecPolicyName)
                               throws IOException

Specified by:

enableErasureCodingPolicy in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

enableErasureCodingPolicy in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

disableErasureCodingPolicy

public void disableErasureCodingPolicy(String ecPolicyName)
                                throws IOException

Specified by:

disableErasureCodingPolicy in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

disableErasureCodingPolicy in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getErasureCodingPolicies

public org.apache.hadoop.hdfs.protocol.ErasureCodingPolicyInfo[] getErasureCodingPolicies()
                                                                                   throws IOException

Specified by:

getErasureCodingPolicies in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getErasureCodingPolicies in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getErasureCodingCodecs

public Map<String,String> getErasureCodingCodecs()
                                          throws IOException

Specified by:

getErasureCodingCodecs in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getErasureCodingCodecs in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getErasureCodingPolicy

public org.apache.hadoop.hdfs.protocol.ErasureCodingPolicy getErasureCodingPolicy(String src)
                                                                           throws IOException

Specified by:

getErasureCodingPolicy in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getErasureCodingPolicy in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getQuotaUsage

public org.apache.hadoop.fs.QuotaUsage getQuotaUsage(String path)
                                              throws IOException

Specified by:

getQuotaUsage in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getQuotaUsage in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

listOpenFiles

public org.apache.hadoop.fs.BatchedRemoteIterator.BatchedEntries<org.apache.hadoop.hdfs.protocol.OpenFileEntry> listOpenFiles(long prevId,
 EnumSet<org.apache.hadoop.hdfs.protocol.OpenFilesIterator.OpenFilesType> openFilesTypes,
 String path)
                                                                                                                       throws IOException

Specified by:

listOpenFiles in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

listOpenFiles in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

msync

public void msync()
           throws IOException

Specified by:

msync in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

msync in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

satisfyStoragePolicy

public void satisfyStoragePolicy(String src)
                          throws IOException

Specified by:

satisfyStoragePolicy in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

satisfyStoragePolicy in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getSlowDatanodeReport

public org.apache.hadoop.hdfs.protocol.DatanodeInfo[] getSlowDatanodeReport()
                                                                     throws IOException

Specified by:

getSlowDatanodeReport in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getSlowDatanodeReport in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getHAServiceState

public org.apache.hadoop.ha.HAServiceProtocol.HAServiceState getHAServiceState()
                                                                        throws IOException

Specified by:

getHAServiceState in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getHAServiceState in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException

getEnclosingRoot

public org.apache.hadoop.fs.Path getEnclosingRoot(String filename)
                                           throws IOException

Specified by:

getEnclosingRoot in interface org.apache.hadoop.hdfs.protocol.ClientProtocol

Overrides:

getEnclosingRoot in class org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB

Throws:

IOException