org.apache.hadoop.hdfs.protocol.proto

Interface DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface

All Known Subinterfaces:

DatanodeProtocolPB

All Known Implementing Classes:

DatanodeProtocolServerSideTranslatorPB

Enclosing class:

DatanodeProtocolProtos.DatanodeProtocolService

public static interface DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface

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)

Method Detail

registerDatanode

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

Throws:

com.google.protobuf.ServiceException

sendHeartbeat

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

Throws:

com.google.protobuf.ServiceException

blockReport

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

Throws:

com.google.protobuf.ServiceException

blockReceivedAndDeleted

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

Throws:

com.google.protobuf.ServiceException

errorReport

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

Throws:

com.google.protobuf.ServiceException

versionRequest

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

Throws:

com.google.protobuf.ServiceException

reportBadBlocks

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

Throws:

com.google.protobuf.ServiceException

commitBlockSynchronization

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

Throws:

com.google.protobuf.ServiceException