Package org.apache.hadoop.hdfs.protocolPB

Class NamenodeProtocolServerSideTranslatorPB

java.lang.Object

org.apache.hadoop.hdfs.protocolPB.NamenodeProtocolServerSideTranslatorPB

All Implemented Interfaces:

org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.NamenodeProtocolService.BlockingInterface, NamenodeProtocolPB

public class NamenodeProtocolServerSideTranslatorPB
extends Object
implements NamenodeProtocolPB

Implementation for protobuf service that forwards requests received on NamenodeProtocolPB to the NamenodeProtocol server implementation.

Field Summary

Fields

Modifier and Type	Field	Description
protected static final org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.EndCheckpointResponseProto	VOID_END_CHECKPOINT_RESPONSE
protected static final org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.ErrorReportResponseProto	VOID_ERROR_REPORT_RESPONSE

Constructor Summary

Constructors

Constructor	Description
NamenodeProtocolServerSideTranslatorPB(NamenodeProtocol impl)

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.EndCheckpointResponseProto	endCheckpoint(org.apache.hadoop.thirdparty.protobuf.RpcController unused, org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.EndCheckpointRequestProto request)
org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.ErrorReportResponseProto	errorReport(org.apache.hadoop.thirdparty.protobuf.RpcController unused, org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.ErrorReportRequestProto request)
org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetBlockKeysResponseProto	getBlockKeys(org.apache.hadoop.thirdparty.protobuf.RpcController unused, org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetBlockKeysRequestProto request)
org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetBlocksResponseProto	getBlocks(org.apache.hadoop.thirdparty.protobuf.RpcController unused, org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetBlocksRequestProto request)
org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetEditLogManifestResponseProto	getEditLogManifest(org.apache.hadoop.thirdparty.protobuf.RpcController unused, org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetEditLogManifestRequestProto request)
org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetMostRecentCheckpointTxIdResponseProto	getMostRecentCheckpointTxId(org.apache.hadoop.thirdparty.protobuf.RpcController unused, org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetMostRecentCheckpointTxIdRequestProto request)
org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetMostRecentNameNodeFileTxIdResponseProto	getMostRecentNameNodeFileTxId(org.apache.hadoop.thirdparty.protobuf.RpcController unused, org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetMostRecentNameNodeFileTxIdRequestProto request)
org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetNextSPSPathResponseProto	getNextSPSPath(org.apache.hadoop.thirdparty.protobuf.RpcController controller, org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetNextSPSPathRequestProto request)
org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetTransactionIdResponseProto	getTransactionId(org.apache.hadoop.thirdparty.protobuf.RpcController unused, org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetTransactionIdRequestProto request)
org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.IsRollingUpgradeResponseProto	isRollingUpgrade(org.apache.hadoop.thirdparty.protobuf.RpcController controller, org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.IsRollingUpgradeRequestProto request)
org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.IsUpgradeFinalizedResponseProto	isUpgradeFinalized(org.apache.hadoop.thirdparty.protobuf.RpcController controller, org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.IsUpgradeFinalizedRequestProto request)
org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.RegisterResponseProto	registerSubordinateNamenode(org.apache.hadoop.thirdparty.protobuf.RpcController unused, org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.RegisterRequestProto request)
org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.RollEditLogResponseProto	rollEditLog(org.apache.hadoop.thirdparty.protobuf.RpcController unused, org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.RollEditLogRequestProto request)
org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.StartCheckpointResponseProto	startCheckpoint(org.apache.hadoop.thirdparty.protobuf.RpcController unused, org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.StartCheckpointRequestProto request)
org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.VersionResponseProto	versionRequest(org.apache.hadoop.thirdparty.protobuf.RpcController controller, org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.VersionRequestProto request)

Methods inherited from class java.lang.Object

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

Field Details

VOID_ERROR_REPORT_RESPONSE

protected static final org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.ErrorReportResponseProto VOID_ERROR_REPORT_RESPONSE

VOID_END_CHECKPOINT_RESPONSE

protected static final org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.EndCheckpointResponseProto VOID_END_CHECKPOINT_RESPONSE

Constructor Details

NamenodeProtocolServerSideTranslatorPB

public NamenodeProtocolServerSideTranslatorPB(NamenodeProtocol impl)

Method Details

getBlocks

public org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetBlocksResponseProto getBlocks(org.apache.hadoop.thirdparty.protobuf.RpcController unused,
 org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetBlocksRequestProto request)
                                                                                              throws org.apache.hadoop.thirdparty.protobuf.ServiceException

Specified by:

getBlocks in interface org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.NamenodeProtocolService.BlockingInterface

Throws:

org.apache.hadoop.thirdparty.protobuf.ServiceException

getBlockKeys

public org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetBlockKeysResponseProto getBlockKeys(org.apache.hadoop.thirdparty.protobuf.RpcController unused,
 org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetBlockKeysRequestProto request)
                                                                                                    throws org.apache.hadoop.thirdparty.protobuf.ServiceException

Specified by:

getBlockKeys in interface org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.NamenodeProtocolService.BlockingInterface

Throws:

org.apache.hadoop.thirdparty.protobuf.ServiceException

getTransactionId

public org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetTransactionIdResponseProto getTransactionId(org.apache.hadoop.thirdparty.protobuf.RpcController unused,
 org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetTransactionIdRequestProto request)
                                                                                                            throws org.apache.hadoop.thirdparty.protobuf.ServiceException

Specified by:

getTransactionId in interface org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.NamenodeProtocolService.BlockingInterface

Throws:

org.apache.hadoop.thirdparty.protobuf.ServiceException

getMostRecentCheckpointTxId

public org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetMostRecentCheckpointTxIdResponseProto getMostRecentCheckpointTxId(org.apache.hadoop.thirdparty.protobuf.RpcController unused,
 org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetMostRecentCheckpointTxIdRequestProto request)
                                                                                                                                  throws org.apache.hadoop.thirdparty.protobuf.ServiceException

Specified by:

getMostRecentCheckpointTxId in interface org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.NamenodeProtocolService.BlockingInterface

Throws:

org.apache.hadoop.thirdparty.protobuf.ServiceException

getMostRecentNameNodeFileTxId

public org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetMostRecentNameNodeFileTxIdResponseProto getMostRecentNameNodeFileTxId(org.apache.hadoop.thirdparty.protobuf.RpcController unused,
 org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetMostRecentNameNodeFileTxIdRequestProto request)
                                                                                                                                      throws org.apache.hadoop.thirdparty.protobuf.ServiceException

Specified by:

getMostRecentNameNodeFileTxId in interface org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.NamenodeProtocolService.BlockingInterface

Throws:

org.apache.hadoop.thirdparty.protobuf.ServiceException

rollEditLog

public org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.RollEditLogResponseProto rollEditLog(org.apache.hadoop.thirdparty.protobuf.RpcController unused,
 org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.RollEditLogRequestProto request)
                                                                                                  throws org.apache.hadoop.thirdparty.protobuf.ServiceException

Specified by:

rollEditLog in interface org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.NamenodeProtocolService.BlockingInterface

Throws:

org.apache.hadoop.thirdparty.protobuf.ServiceException

errorReport

public org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.ErrorReportResponseProto errorReport(org.apache.hadoop.thirdparty.protobuf.RpcController unused,
 org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.ErrorReportRequestProto request)
                                                                                                  throws org.apache.hadoop.thirdparty.protobuf.ServiceException

Specified by:

errorReport in interface org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.NamenodeProtocolService.BlockingInterface

Throws:

org.apache.hadoop.thirdparty.protobuf.ServiceException

registerSubordinateNamenode

public org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.RegisterResponseProto registerSubordinateNamenode(org.apache.hadoop.thirdparty.protobuf.RpcController unused,
 org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.RegisterRequestProto request)
                                                                                                               throws org.apache.hadoop.thirdparty.protobuf.ServiceException

Specified by:

registerSubordinateNamenode in interface org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.NamenodeProtocolService.BlockingInterface

Throws:

org.apache.hadoop.thirdparty.protobuf.ServiceException

startCheckpoint

public org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.StartCheckpointResponseProto startCheckpoint(org.apache.hadoop.thirdparty.protobuf.RpcController unused,
 org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.StartCheckpointRequestProto request)
                                                                                                          throws org.apache.hadoop.thirdparty.protobuf.ServiceException

Specified by:

startCheckpoint in interface org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.NamenodeProtocolService.BlockingInterface

Throws:

org.apache.hadoop.thirdparty.protobuf.ServiceException

endCheckpoint

public org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.EndCheckpointResponseProto endCheckpoint(org.apache.hadoop.thirdparty.protobuf.RpcController unused,
 org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.EndCheckpointRequestProto request)
                                                                                                      throws org.apache.hadoop.thirdparty.protobuf.ServiceException

Specified by:

endCheckpoint in interface org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.NamenodeProtocolService.BlockingInterface

Throws:

org.apache.hadoop.thirdparty.protobuf.ServiceException

getEditLogManifest

public org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetEditLogManifestResponseProto getEditLogManifest(org.apache.hadoop.thirdparty.protobuf.RpcController unused,
 org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetEditLogManifestRequestProto request)
                                                                                                                throws org.apache.hadoop.thirdparty.protobuf.ServiceException

Specified by:

getEditLogManifest in interface org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.NamenodeProtocolService.BlockingInterface

Throws:

org.apache.hadoop.thirdparty.protobuf.ServiceException

versionRequest

public org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.VersionResponseProto versionRequest(org.apache.hadoop.thirdparty.protobuf.RpcController controller,
 org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.VersionRequestProto request)
                                                                                           throws org.apache.hadoop.thirdparty.protobuf.ServiceException

Specified by:

versionRequest in interface org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.NamenodeProtocolService.BlockingInterface

Throws:

org.apache.hadoop.thirdparty.protobuf.ServiceException

isUpgradeFinalized

public org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.IsUpgradeFinalizedResponseProto isUpgradeFinalized(org.apache.hadoop.thirdparty.protobuf.RpcController controller,
 org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.IsUpgradeFinalizedRequestProto request)
                                                                                                                throws org.apache.hadoop.thirdparty.protobuf.ServiceException

Specified by:

isUpgradeFinalized in interface org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.NamenodeProtocolService.BlockingInterface

Throws:

org.apache.hadoop.thirdparty.protobuf.ServiceException

isRollingUpgrade

public org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.IsRollingUpgradeResponseProto isRollingUpgrade(org.apache.hadoop.thirdparty.protobuf.RpcController controller,
 org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.IsRollingUpgradeRequestProto request)
                                                                                                            throws org.apache.hadoop.thirdparty.protobuf.ServiceException

Specified by:

isRollingUpgrade in interface org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.NamenodeProtocolService.BlockingInterface

Throws:

org.apache.hadoop.thirdparty.protobuf.ServiceException

getNextSPSPath

public org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetNextSPSPathResponseProto getNextSPSPath(org.apache.hadoop.thirdparty.protobuf.RpcController controller,
 org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetNextSPSPathRequestProto request)
                                                                                                        throws org.apache.hadoop.thirdparty.protobuf.ServiceException

Specified by:

getNextSPSPath in interface org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.NamenodeProtocolService.BlockingInterface

Throws:

org.apache.hadoop.thirdparty.protobuf.ServiceException