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, org.apache.hadoop.hdfs.protocolPB.NamenodeProtocolPB

public class NamenodeProtocolServerSideTranslatorPB
extends Object
implements org.apache.hadoop.hdfs.protocolPB.NamenodeProtocolPB

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

Constructor Summary

Constructors

Constructor and Description
NamenodeProtocolServerSideTranslatorPB(org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol impl)

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.EndCheckpointResponseProto	endCheckpoint(com.google.protobuf.RpcController unused, org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.EndCheckpointRequestProto request)
org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.ErrorReportResponseProto	errorReport(com.google.protobuf.RpcController unused, org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.ErrorReportRequestProto request)
org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetBlockKeysResponseProto	getBlockKeys(com.google.protobuf.RpcController unused, org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetBlockKeysRequestProto request)
org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetBlocksResponseProto	getBlocks(com.google.protobuf.RpcController unused, org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetBlocksRequestProto request)
org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetEditLogManifestResponseProto	getEditLogManifest(com.google.protobuf.RpcController unused, org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetEditLogManifestRequestProto request)
org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetMostRecentCheckpointTxIdResponseProto	getMostRecentCheckpointTxId(com.google.protobuf.RpcController unused, org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetMostRecentCheckpointTxIdRequestProto request)
org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetTransactionIdResponseProto	getTransactionId(com.google.protobuf.RpcController unused, org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.GetTransactionIdRequestProto request)
org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.IsUpgradeFinalizedResponseProto	isUpgradeFinalized(com.google.protobuf.RpcController controller, org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.IsUpgradeFinalizedRequestProto request)
org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.RegisterResponseProto	registerSubordinateNamenode(com.google.protobuf.RpcController unused, org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.RegisterRequestProto request)
org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.RollEditLogResponseProto	rollEditLog(com.google.protobuf.RpcController unused, org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.RollEditLogRequestProto request)
org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.StartCheckpointResponseProto	startCheckpoint(com.google.protobuf.RpcController unused, org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.StartCheckpointRequestProto request)
org.apache.hadoop.hdfs.protocol.proto.HdfsServerProtos.VersionResponseProto	versionRequest(com.google.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

Constructor Detail

NamenodeProtocolServerSideTranslatorPB

public NamenodeProtocolServerSideTranslatorPB(org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol impl)

Method Detail

getBlocks

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

Specified by:

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

Throws:

com.google.protobuf.ServiceException

getBlockKeys

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

Specified by:

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

Throws:

com.google.protobuf.ServiceException

getTransactionId

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

Specified by:

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

Throws:

com.google.protobuf.ServiceException

getMostRecentCheckpointTxId

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

Specified by:

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

Throws:

com.google.protobuf.ServiceException

rollEditLog

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

Specified by:

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

Throws:

com.google.protobuf.ServiceException

errorReport

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

Specified by:

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

Throws:

com.google.protobuf.ServiceException

registerSubordinateNamenode

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

Specified by:

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

Throws:

com.google.protobuf.ServiceException

startCheckpoint

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

Specified by:

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

Throws:

com.google.protobuf.ServiceException

endCheckpoint

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

Specified by:

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

Throws:

com.google.protobuf.ServiceException

getEditLogManifest

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

Specified by:

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

Throws:

com.google.protobuf.ServiceException

versionRequest

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

Specified by:

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

Throws:

com.google.protobuf.ServiceException

isUpgradeFinalized

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

Specified by:

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

Throws:

com.google.protobuf.ServiceException