Package org.apache.hadoop.hdfs.protocolPB

Class RouterNamenodeProtocolTranslatorPB

java.lang.Object

org.apache.hadoop.hdfs.protocolPB.NamenodeProtocolTranslatorPB

org.apache.hadoop.hdfs.protocolPB.RouterNamenodeProtocolTranslatorPB

All Implemented Interfaces:

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

public class RouterNamenodeProtocolTranslatorPB
extends org.apache.hadoop.hdfs.protocolPB.NamenodeProtocolTranslatorPB

Field Summary

Fields inherited from interface org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol

ACT_CHECKPOINT, ACT_SHUTDOWN, ACT_UNKNOWN, FATAL, NOTIFY, versionID

Constructor Summary

Constructors

Constructor	Description
RouterNamenodeProtocolTranslatorPB(org.apache.hadoop.hdfs.protocolPB.NamenodeProtocolPB rpcProxy)

Method Summary

Modifier and Type	Method	Description
void	endCheckpoint(org.apache.hadoop.hdfs.server.protocol.NamenodeRegistration registration, org.apache.hadoop.hdfs.server.namenode.CheckpointSignature sig)
void	errorReport(org.apache.hadoop.hdfs.server.protocol.NamenodeRegistration registration, int errorCode, String msg)
org.apache.hadoop.hdfs.security.token.block.ExportedBlockKeys	getBlockKeys()
org.apache.hadoop.hdfs.server.protocol.BlocksWithLocations	getBlocks(org.apache.hadoop.hdfs.protocol.DatanodeInfo datanode, long size, long minBlockSize, long timeInterval, org.apache.hadoop.fs.StorageType storageType)
org.apache.hadoop.hdfs.server.protocol.RemoteEditLogManifest	getEditLogManifest(long sinceTxId)
long	getMostRecentCheckpointTxId()
long	getMostRecentNameNodeFileTxId(org.apache.hadoop.hdfs.server.namenode.NNStorage.NameNodeFile nnf)
Long	getNextSPSPath()
long	getTransactionID()
boolean	isRollingUpgrade()
boolean	isUpgradeFinalized()
org.apache.hadoop.hdfs.server.protocol.NamenodeRegistration	registerSubordinateNamenode(org.apache.hadoop.hdfs.server.protocol.NamenodeRegistration registration)
org.apache.hadoop.hdfs.server.namenode.CheckpointSignature	rollEditLog()
org.apache.hadoop.hdfs.server.protocol.NamenodeCommand	startCheckpoint(org.apache.hadoop.hdfs.server.protocol.NamenodeRegistration registration)
org.apache.hadoop.hdfs.server.protocol.NamespaceInfo	versionRequest()

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

close, getUnderlyingProxyObject, isMethodSupported

Methods inherited from class java.lang.Object

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

Constructor Details

RouterNamenodeProtocolTranslatorPB

public RouterNamenodeProtocolTranslatorPB(org.apache.hadoop.hdfs.protocolPB.NamenodeProtocolPB rpcProxy)

Method Details

getBlocks

public org.apache.hadoop.hdfs.server.protocol.BlocksWithLocations getBlocks(org.apache.hadoop.hdfs.protocol.DatanodeInfo datanode,
 long size,
 long minBlockSize,
 long timeInterval,
 org.apache.hadoop.fs.StorageType storageType)
                                                                     throws IOException

Specified by:

getBlocks in interface org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol

Overrides:

getBlocks in class org.apache.hadoop.hdfs.protocolPB.NamenodeProtocolTranslatorPB

Throws:

IOException

getBlockKeys

public org.apache.hadoop.hdfs.security.token.block.ExportedBlockKeys getBlockKeys()
                                                                           throws IOException

Specified by:

getBlockKeys in interface org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol

Overrides:

getBlockKeys in class org.apache.hadoop.hdfs.protocolPB.NamenodeProtocolTranslatorPB

Throws:

IOException

getTransactionID

public long getTransactionID()
                      throws IOException

Specified by:

getTransactionID in interface org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol

Overrides:

getTransactionID in class org.apache.hadoop.hdfs.protocolPB.NamenodeProtocolTranslatorPB

Throws:

IOException

getMostRecentCheckpointTxId

public long getMostRecentCheckpointTxId()
                                 throws IOException

Specified by:

getMostRecentCheckpointTxId in interface org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol

Overrides:

getMostRecentCheckpointTxId in class org.apache.hadoop.hdfs.protocolPB.NamenodeProtocolTranslatorPB

Throws:

IOException

getMostRecentNameNodeFileTxId

public long getMostRecentNameNodeFileTxId(org.apache.hadoop.hdfs.server.namenode.NNStorage.NameNodeFile nnf)
                                   throws IOException

Specified by:

getMostRecentNameNodeFileTxId in interface org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol

Overrides:

getMostRecentNameNodeFileTxId in class org.apache.hadoop.hdfs.protocolPB.NamenodeProtocolTranslatorPB

Throws:

IOException

rollEditLog

public org.apache.hadoop.hdfs.server.namenode.CheckpointSignature rollEditLog()
                                                                       throws IOException

Specified by:

rollEditLog in interface org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol

Overrides:

rollEditLog in class org.apache.hadoop.hdfs.protocolPB.NamenodeProtocolTranslatorPB

Throws:

IOException

versionRequest

public org.apache.hadoop.hdfs.server.protocol.NamespaceInfo versionRequest()
                                                                    throws IOException

Specified by:

versionRequest in interface org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol

Overrides:

versionRequest in class org.apache.hadoop.hdfs.protocolPB.NamenodeProtocolTranslatorPB

Throws:

IOException

errorReport

public void errorReport(org.apache.hadoop.hdfs.server.protocol.NamenodeRegistration registration,
 int errorCode,
 String msg)
                 throws IOException

Specified by:

errorReport in interface org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol

Overrides:

errorReport in class org.apache.hadoop.hdfs.protocolPB.NamenodeProtocolTranslatorPB

Throws:

IOException

registerSubordinateNamenode

public org.apache.hadoop.hdfs.server.protocol.NamenodeRegistration registerSubordinateNamenode(org.apache.hadoop.hdfs.server.protocol.NamenodeRegistration registration)
                                                                                        throws IOException

Specified by:

registerSubordinateNamenode in interface org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol

Overrides:

registerSubordinateNamenode in class org.apache.hadoop.hdfs.protocolPB.NamenodeProtocolTranslatorPB

Throws:

IOException

startCheckpoint

public org.apache.hadoop.hdfs.server.protocol.NamenodeCommand startCheckpoint(org.apache.hadoop.hdfs.server.protocol.NamenodeRegistration registration)
                                                                       throws IOException

Specified by:

startCheckpoint in interface org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol

Overrides:

startCheckpoint in class org.apache.hadoop.hdfs.protocolPB.NamenodeProtocolTranslatorPB

Throws:

IOException

endCheckpoint

public void endCheckpoint(org.apache.hadoop.hdfs.server.protocol.NamenodeRegistration registration,
 org.apache.hadoop.hdfs.server.namenode.CheckpointSignature sig)
                   throws IOException

Specified by:

endCheckpoint in interface org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol

Overrides:

endCheckpoint in class org.apache.hadoop.hdfs.protocolPB.NamenodeProtocolTranslatorPB

Throws:

IOException

getEditLogManifest

public org.apache.hadoop.hdfs.server.protocol.RemoteEditLogManifest getEditLogManifest(long sinceTxId)
                                                                                throws IOException

Specified by:

getEditLogManifest in interface org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol

Overrides:

getEditLogManifest in class org.apache.hadoop.hdfs.protocolPB.NamenodeProtocolTranslatorPB

Throws:

IOException

isUpgradeFinalized

public boolean isUpgradeFinalized()
                           throws IOException

Specified by:

isUpgradeFinalized in interface org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol

Overrides:

isUpgradeFinalized in class org.apache.hadoop.hdfs.protocolPB.NamenodeProtocolTranslatorPB

Throws:

IOException

isRollingUpgrade

public boolean isRollingUpgrade()
                         throws IOException

Specified by:

isRollingUpgrade in interface org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol

Overrides:

isRollingUpgrade in class org.apache.hadoop.hdfs.protocolPB.NamenodeProtocolTranslatorPB

Throws:

IOException

getNextSPSPath

public Long getNextSPSPath()
                    throws IOException

Specified by:

getNextSPSPath in interface org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol

Overrides:

getNextSPSPath in class org.apache.hadoop.hdfs.protocolPB.NamenodeProtocolTranslatorPB

Throws:

IOException