org.apache.hadoop.hdfs.protocolPB

Class DatanodeProtocolServerSideTranslatorPB

java.lang.Object

org.apache.hadoop.hdfs.protocolPB.DatanodeProtocolServerSideTranslatorPB

All Implemented Interfaces:

DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface, DatanodeProtocolPB

public class DatanodeProtocolServerSideTranslatorPB
extends Object
implements DatanodeProtocolPB

Constructor Summary

Constructors

Constructor and Description
DatanodeProtocolServerSideTranslatorPB(DatanodeProtocol impl)

Method Summary

Methods

Modifier and Type	Method and Description
DatanodeProtocolProtos.BlockReceivedAndDeletedResponseProto	blockReceivedAndDeleted(com.google.protobuf.RpcController controller, DatanodeProtocolProtos.BlockReceivedAndDeletedRequestProto request)
DatanodeProtocolProtos.BlockReportResponseProto	blockReport(com.google.protobuf.RpcController controller, DatanodeProtocolProtos.BlockReportRequestProto request)
DatanodeProtocolProtos.CommitBlockSynchronizationResponseProto	commitBlockSynchronization(com.google.protobuf.RpcController controller, DatanodeProtocolProtos.CommitBlockSynchronizationRequestProto request)
DatanodeProtocolProtos.ErrorReportResponseProto	errorReport(com.google.protobuf.RpcController controller, DatanodeProtocolProtos.ErrorReportRequestProto request)
DatanodeProtocolProtos.RegisterDatanodeResponseProto	registerDatanode(com.google.protobuf.RpcController controller, DatanodeProtocolProtos.RegisterDatanodeRequestProto request)
DatanodeProtocolProtos.ReportBadBlocksResponseProto	reportBadBlocks(com.google.protobuf.RpcController controller, DatanodeProtocolProtos.ReportBadBlocksRequestProto request)
DatanodeProtocolProtos.HeartbeatResponseProto	sendHeartbeat(com.google.protobuf.RpcController controller, DatanodeProtocolProtos.HeartbeatRequestProto request)
HdfsProtos.VersionResponseProto	versionRequest(com.google.protobuf.RpcController controller, HdfsProtos.VersionRequestProto request)

Methods inherited from class java.lang.Object

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

Constructor Detail

DatanodeProtocolServerSideTranslatorPB

public DatanodeProtocolServerSideTranslatorPB(DatanodeProtocol impl)

Method Detail

registerDatanode

public DatanodeProtocolProtos.RegisterDatanodeResponseProto registerDatanode(com.google.protobuf.RpcController controller,
                                                                    DatanodeProtocolProtos.RegisterDatanodeRequestProto request)
                                                                      throws com.google.protobuf.ServiceException

Specified by:

registerDatanode in interface DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

sendHeartbeat

public DatanodeProtocolProtos.HeartbeatResponseProto sendHeartbeat(com.google.protobuf.RpcController controller,
                                                          DatanodeProtocolProtos.HeartbeatRequestProto request)
                                                            throws com.google.protobuf.ServiceException

Specified by:

sendHeartbeat in interface DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

blockReport

public DatanodeProtocolProtos.BlockReportResponseProto blockReport(com.google.protobuf.RpcController controller,
                                                          DatanodeProtocolProtos.BlockReportRequestProto request)
                                                            throws com.google.protobuf.ServiceException

Specified by:

blockReport in interface DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

blockReceivedAndDeleted

public DatanodeProtocolProtos.BlockReceivedAndDeletedResponseProto blockReceivedAndDeleted(com.google.protobuf.RpcController controller,
                                                                                  DatanodeProtocolProtos.BlockReceivedAndDeletedRequestProto request)
                                                                                    throws com.google.protobuf.ServiceException

Specified by:

blockReceivedAndDeleted in interface DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

errorReport

public DatanodeProtocolProtos.ErrorReportResponseProto errorReport(com.google.protobuf.RpcController controller,
                                                          DatanodeProtocolProtos.ErrorReportRequestProto request)
                                                            throws com.google.protobuf.ServiceException

Specified by:

errorReport in interface DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

versionRequest

public HdfsProtos.VersionResponseProto versionRequest(com.google.protobuf.RpcController controller,
                                             HdfsProtos.VersionRequestProto request)
                                               throws com.google.protobuf.ServiceException

Specified by:

versionRequest in interface DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

reportBadBlocks

public DatanodeProtocolProtos.ReportBadBlocksResponseProto reportBadBlocks(com.google.protobuf.RpcController controller,
                                                                  DatanodeProtocolProtos.ReportBadBlocksRequestProto request)
                                                                    throws com.google.protobuf.ServiceException

Specified by:

reportBadBlocks in interface DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

commitBlockSynchronization

public DatanodeProtocolProtos.CommitBlockSynchronizationResponseProto commitBlockSynchronization(com.google.protobuf.RpcController controller,
                                                                                        DatanodeProtocolProtos.CommitBlockSynchronizationRequestProto request)
                                                                                          throws com.google.protobuf.ServiceException

Specified by:

commitBlockSynchronization in interface DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException