public class DatanodeProtocolServerSideTranslatorPB extends Object implements DatanodeProtocolPB
Constructor and Description |
---|
DatanodeProtocolServerSideTranslatorPB(DatanodeProtocol impl) |
public DatanodeProtocolServerSideTranslatorPB(DatanodeProtocol impl)
public DatanodeProtocolProtos.RegisterDatanodeResponseProto registerDatanode(com.google.protobuf.RpcController controller, DatanodeProtocolProtos.RegisterDatanodeRequestProto request) throws com.google.protobuf.ServiceException
registerDatanode
in interface DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface
com.google.protobuf.ServiceException
public DatanodeProtocolProtos.HeartbeatResponseProto sendHeartbeat(com.google.protobuf.RpcController controller, DatanodeProtocolProtos.HeartbeatRequestProto request) throws com.google.protobuf.ServiceException
sendHeartbeat
in interface DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface
com.google.protobuf.ServiceException
public DatanodeProtocolProtos.BlockReportResponseProto blockReport(com.google.protobuf.RpcController controller, DatanodeProtocolProtos.BlockReportRequestProto request) throws com.google.protobuf.ServiceException
blockReport
in interface DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface
com.google.protobuf.ServiceException
public DatanodeProtocolProtos.BlockReceivedAndDeletedResponseProto blockReceivedAndDeleted(com.google.protobuf.RpcController controller, DatanodeProtocolProtos.BlockReceivedAndDeletedRequestProto request) throws com.google.protobuf.ServiceException
blockReceivedAndDeleted
in interface DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface
com.google.protobuf.ServiceException
public DatanodeProtocolProtos.ErrorReportResponseProto errorReport(com.google.protobuf.RpcController controller, DatanodeProtocolProtos.ErrorReportRequestProto request) throws com.google.protobuf.ServiceException
errorReport
in interface DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface
com.google.protobuf.ServiceException
public HdfsProtos.VersionResponseProto versionRequest(com.google.protobuf.RpcController controller, HdfsProtos.VersionRequestProto request) throws com.google.protobuf.ServiceException
versionRequest
in interface DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface
com.google.protobuf.ServiceException
public DatanodeProtocolProtos.ReportBadBlocksResponseProto reportBadBlocks(com.google.protobuf.RpcController controller, DatanodeProtocolProtos.ReportBadBlocksRequestProto request) throws com.google.protobuf.ServiceException
reportBadBlocks
in interface DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface
com.google.protobuf.ServiceException
public DatanodeProtocolProtos.CommitBlockSynchronizationResponseProto commitBlockSynchronization(com.google.protobuf.RpcController controller, DatanodeProtocolProtos.CommitBlockSynchronizationRequestProto request) throws com.google.protobuf.ServiceException
commitBlockSynchronization
in interface DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface
com.google.protobuf.ServiceException
Copyright © 2013 Apache Software Foundation. All rights reserved.