Package org.apache.hadoop.hdfs.protocolPB

Class DatanodeProtocolServerSideTranslatorPB

java.lang.Object

org.apache.hadoop.hdfs.protocolPB.DatanodeProtocolServerSideTranslatorPB

All Implemented Interfaces:

org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface, DatanodeProtocolPB

public class DatanodeProtocolServerSideTranslatorPB
extends Object
implements DatanodeProtocolPB

Constructor Summary

Constructors

Constructor	Description
DatanodeProtocolServerSideTranslatorPB(DatanodeProtocol impl, int maxDataLength)

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.BlockReceivedAndDeletedResponseProto	blockReceivedAndDeleted(org.apache.hadoop.thirdparty.protobuf.RpcController controller, org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.BlockReceivedAndDeletedRequestProto request)
org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.BlockReportResponseProto	blockReport(org.apache.hadoop.thirdparty.protobuf.RpcController controller, org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.BlockReportRequestProto request)
org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.CacheReportResponseProto	cacheReport(org.apache.hadoop.thirdparty.protobuf.RpcController controller, org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.CacheReportRequestProto request)
org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.CommitBlockSynchronizationResponseProto	commitBlockSynchronization(org.apache.hadoop.thirdparty.protobuf.RpcController controller, org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.CommitBlockSynchronizationRequestProto request)
org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.ErrorReportResponseProto	errorReport(org.apache.hadoop.thirdparty.protobuf.RpcController controller, org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.ErrorReportRequestProto request)
org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.RegisterDatanodeResponseProto	registerDatanode(org.apache.hadoop.thirdparty.protobuf.RpcController controller, org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.RegisterDatanodeRequestProto request)
org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.ReportBadBlocksResponseProto	reportBadBlocks(org.apache.hadoop.thirdparty.protobuf.RpcController controller, org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.ReportBadBlocksRequestProto request)
org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.HeartbeatResponseProto	sendHeartbeat(org.apache.hadoop.thirdparty.protobuf.RpcController controller, org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.HeartbeatRequestProto 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

Constructor Details

DatanodeProtocolServerSideTranslatorPB

public DatanodeProtocolServerSideTranslatorPB(DatanodeProtocol impl,
 int maxDataLength)

Method Details

registerDatanode

public org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.RegisterDatanodeResponseProto registerDatanode(org.apache.hadoop.thirdparty.protobuf.RpcController controller,
 org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.RegisterDatanodeRequestProto request)
                                                                                                            throws org.apache.hadoop.thirdparty.protobuf.ServiceException

Specified by:

registerDatanode in interface org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface

Throws:

org.apache.hadoop.thirdparty.protobuf.ServiceException

sendHeartbeat

public org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.HeartbeatResponseProto sendHeartbeat(org.apache.hadoop.thirdparty.protobuf.RpcController controller,
 org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.HeartbeatRequestProto request)
                                                                                                  throws org.apache.hadoop.thirdparty.protobuf.ServiceException

Specified by:

sendHeartbeat in interface org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface

Throws:

org.apache.hadoop.thirdparty.protobuf.ServiceException

blockReport

public org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.BlockReportResponseProto blockReport(org.apache.hadoop.thirdparty.protobuf.RpcController controller,
 org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.BlockReportRequestProto request)
                                                                                                  throws org.apache.hadoop.thirdparty.protobuf.ServiceException

Specified by:

blockReport in interface org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface

Throws:

org.apache.hadoop.thirdparty.protobuf.ServiceException

cacheReport

public org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.CacheReportResponseProto cacheReport(org.apache.hadoop.thirdparty.protobuf.RpcController controller,
 org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.CacheReportRequestProto request)
                                                                                                  throws org.apache.hadoop.thirdparty.protobuf.ServiceException

Specified by:

cacheReport in interface org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface

Throws:

org.apache.hadoop.thirdparty.protobuf.ServiceException

blockReceivedAndDeleted

public org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.BlockReceivedAndDeletedResponseProto blockReceivedAndDeleted(org.apache.hadoop.thirdparty.protobuf.RpcController controller,
 org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.BlockReceivedAndDeletedRequestProto request)
                                                                                                                          throws org.apache.hadoop.thirdparty.protobuf.ServiceException

Specified by:

blockReceivedAndDeleted in interface org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface

Throws:

org.apache.hadoop.thirdparty.protobuf.ServiceException

errorReport

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

Specified by:

errorReport in interface org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.DatanodeProtocolService.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.DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface

Throws:

org.apache.hadoop.thirdparty.protobuf.ServiceException

reportBadBlocks

public org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.ReportBadBlocksResponseProto reportBadBlocks(org.apache.hadoop.thirdparty.protobuf.RpcController controller,
 org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.ReportBadBlocksRequestProto request)
                                                                                                          throws org.apache.hadoop.thirdparty.protobuf.ServiceException

Specified by:

reportBadBlocks in interface org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface

Throws:

org.apache.hadoop.thirdparty.protobuf.ServiceException

commitBlockSynchronization

public org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.CommitBlockSynchronizationResponseProto commitBlockSynchronization(org.apache.hadoop.thirdparty.protobuf.RpcController controller,
 org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.CommitBlockSynchronizationRequestProto request)
                                                                                                                                throws org.apache.hadoop.thirdparty.protobuf.ServiceException

Specified by:

commitBlockSynchronization in interface org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface

Throws:

org.apache.hadoop.thirdparty.protobuf.ServiceException