org.apache.hadoop.hdfs.protocol.proto

Class DatanodeProtocolProtos.DatanodeProtocolService.Stub

java.lang.Object

org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.DatanodeProtocolService

org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.DatanodeProtocolService.Stub

All Implemented Interfaces:

com.google.protobuf.Service, DatanodeProtocolProtos.DatanodeProtocolService.Interface

Enclosing class:

DatanodeProtocolProtos.DatanodeProtocolService

public static final class DatanodeProtocolProtos.DatanodeProtocolService.Stub
extends DatanodeProtocolProtos.DatanodeProtocolService
implements DatanodeProtocolProtos.DatanodeProtocolService.Interface

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.DatanodeProtocolService

DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface, DatanodeProtocolProtos.DatanodeProtocolService.Interface, DatanodeProtocolProtos.DatanodeProtocolService.Stub

Method Summary

Methods

Modifier and Type	Method and Description
void	blockReceivedAndDeleted(com.google.protobuf.RpcController controller, DatanodeProtocolProtos.BlockReceivedAndDeletedRequestProto request, com.google.protobuf.RpcCallback<DatanodeProtocolProtos.BlockReceivedAndDeletedResponseProto> done) rpc blockReceivedAndDeleted(.hadoop.hdfs.BlockReceivedAndDeletedRequestProto) returns (.hadoop.hdfs.BlockReceivedAndDeletedResponseProto);
void	blockReport(com.google.protobuf.RpcController controller, DatanodeProtocolProtos.BlockReportRequestProto request, com.google.protobuf.RpcCallback<DatanodeProtocolProtos.BlockReportResponseProto> done) rpc blockReport(.hadoop.hdfs.BlockReportRequestProto) returns (.hadoop.hdfs.BlockReportResponseProto);
void	commitBlockSynchronization(com.google.protobuf.RpcController controller, DatanodeProtocolProtos.CommitBlockSynchronizationRequestProto request, com.google.protobuf.RpcCallback<DatanodeProtocolProtos.CommitBlockSynchronizationResponseProto> done) rpc commitBlockSynchronization(.hadoop.hdfs.CommitBlockSynchronizationRequestProto) returns (.hadoop.hdfs.CommitBlockSynchronizationResponseProto);
void	errorReport(com.google.protobuf.RpcController controller, DatanodeProtocolProtos.ErrorReportRequestProto request, com.google.protobuf.RpcCallback<DatanodeProtocolProtos.ErrorReportResponseProto> done) rpc errorReport(.hadoop.hdfs.ErrorReportRequestProto) returns (.hadoop.hdfs.ErrorReportResponseProto);
com.google.protobuf.RpcChannel	getChannel()
void	registerDatanode(com.google.protobuf.RpcController controller, DatanodeProtocolProtos.RegisterDatanodeRequestProto request, com.google.protobuf.RpcCallback<DatanodeProtocolProtos.RegisterDatanodeResponseProto> done) rpc registerDatanode(.hadoop.hdfs.RegisterDatanodeRequestProto) returns (.hadoop.hdfs.RegisterDatanodeResponseProto);
void	reportBadBlocks(com.google.protobuf.RpcController controller, DatanodeProtocolProtos.ReportBadBlocksRequestProto request, com.google.protobuf.RpcCallback<DatanodeProtocolProtos.ReportBadBlocksResponseProto> done) rpc reportBadBlocks(.hadoop.hdfs.ReportBadBlocksRequestProto) returns (.hadoop.hdfs.ReportBadBlocksResponseProto);
void	sendHeartbeat(com.google.protobuf.RpcController controller, DatanodeProtocolProtos.HeartbeatRequestProto request, com.google.protobuf.RpcCallback<DatanodeProtocolProtos.HeartbeatResponseProto> done) rpc sendHeartbeat(.hadoop.hdfs.HeartbeatRequestProto) returns (.hadoop.hdfs.HeartbeatResponseProto);
void	versionRequest(com.google.protobuf.RpcController controller, HdfsProtos.VersionRequestProto request, com.google.protobuf.RpcCallback<HdfsProtos.VersionResponseProto> done) rpc versionRequest(.hadoop.hdfs.VersionRequestProto) returns (.hadoop.hdfs.VersionResponseProto);

Methods inherited from class org.apache.hadoop.hdfs.protocol.proto.DatanodeProtocolProtos.DatanodeProtocolService

callMethod, getDescriptor, getDescriptorForType, getRequestPrototype, getResponsePrototype, newBlockingStub, newReflectiveBlockingService, newReflectiveService, newStub

Methods inherited from class java.lang.Object

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

Method Detail

getChannel

public com.google.protobuf.RpcChannel getChannel()

registerDatanode

public void registerDatanode(com.google.protobuf.RpcController controller,
                    DatanodeProtocolProtos.RegisterDatanodeRequestProto request,
                    com.google.protobuf.RpcCallback<DatanodeProtocolProtos.RegisterDatanodeResponseProto> done)

Description copied from class: DatanodeProtocolProtos.DatanodeProtocolService

rpc registerDatanode(.hadoop.hdfs.RegisterDatanodeRequestProto) returns (.hadoop.hdfs.RegisterDatanodeResponseProto);

 Register a datanode at a namenode
 

Specified by:

registerDatanode in interface DatanodeProtocolProtos.DatanodeProtocolService.Interface

Specified by:

registerDatanode in class DatanodeProtocolProtos.DatanodeProtocolService

sendHeartbeat

public void sendHeartbeat(com.google.protobuf.RpcController controller,
                 DatanodeProtocolProtos.HeartbeatRequestProto request,
                 com.google.protobuf.RpcCallback<DatanodeProtocolProtos.HeartbeatResponseProto> done)

Description copied from class: DatanodeProtocolProtos.DatanodeProtocolService

rpc sendHeartbeat(.hadoop.hdfs.HeartbeatRequestProto) returns (.hadoop.hdfs.HeartbeatResponseProto);

 Send heartbeat from datanode to namenode
 

Specified by:

sendHeartbeat in interface DatanodeProtocolProtos.DatanodeProtocolService.Interface

Specified by:

sendHeartbeat in class DatanodeProtocolProtos.DatanodeProtocolService

blockReport

public void blockReport(com.google.protobuf.RpcController controller,
               DatanodeProtocolProtos.BlockReportRequestProto request,
               com.google.protobuf.RpcCallback<DatanodeProtocolProtos.BlockReportResponseProto> done)

Description copied from class: DatanodeProtocolProtos.DatanodeProtocolService

rpc blockReport(.hadoop.hdfs.BlockReportRequestProto) returns (.hadoop.hdfs.BlockReportResponseProto);

 Report blocks at a given datanode to the namenode
 

Specified by:

blockReport in interface DatanodeProtocolProtos.DatanodeProtocolService.Interface

Specified by:

blockReport in class DatanodeProtocolProtos.DatanodeProtocolService

blockReceivedAndDeleted

public void blockReceivedAndDeleted(com.google.protobuf.RpcController controller,
                           DatanodeProtocolProtos.BlockReceivedAndDeletedRequestProto request,
                           com.google.protobuf.RpcCallback<DatanodeProtocolProtos.BlockReceivedAndDeletedResponseProto> done)

Description copied from class: DatanodeProtocolProtos.DatanodeProtocolService

rpc blockReceivedAndDeleted(.hadoop.hdfs.BlockReceivedAndDeletedRequestProto) returns (.hadoop.hdfs.BlockReceivedAndDeletedResponseProto);

 Incremental block report from the DN. This contains info about recently
 received and deleted blocks, as well as when blocks start being
 received.
 

Specified by:

blockReceivedAndDeleted in interface DatanodeProtocolProtos.DatanodeProtocolService.Interface

Specified by:

blockReceivedAndDeleted in class DatanodeProtocolProtos.DatanodeProtocolService

errorReport

public void errorReport(com.google.protobuf.RpcController controller,
               DatanodeProtocolProtos.ErrorReportRequestProto request,
               com.google.protobuf.RpcCallback<DatanodeProtocolProtos.ErrorReportResponseProto> done)

Description copied from class: DatanodeProtocolProtos.DatanodeProtocolService

rpc errorReport(.hadoop.hdfs.ErrorReportRequestProto) returns (.hadoop.hdfs.ErrorReportResponseProto);

 Report from a datanode of an error to the active namenode.
 Used for debugging.
 

Specified by:

errorReport in interface DatanodeProtocolProtos.DatanodeProtocolService.Interface

Specified by:

errorReport in class DatanodeProtocolProtos.DatanodeProtocolService

versionRequest

public void versionRequest(com.google.protobuf.RpcController controller,
                  HdfsProtos.VersionRequestProto request,
                  com.google.protobuf.RpcCallback<HdfsProtos.VersionResponseProto> done)

Description copied from class: DatanodeProtocolProtos.DatanodeProtocolService

rpc versionRequest(.hadoop.hdfs.VersionRequestProto) returns (.hadoop.hdfs.VersionResponseProto);

 Request the version
 

Specified by:

versionRequest in interface DatanodeProtocolProtos.DatanodeProtocolService.Interface

Specified by:

versionRequest in class DatanodeProtocolProtos.DatanodeProtocolService

reportBadBlocks

public void reportBadBlocks(com.google.protobuf.RpcController controller,
                   DatanodeProtocolProtos.ReportBadBlocksRequestProto request,
                   com.google.protobuf.RpcCallback<DatanodeProtocolProtos.ReportBadBlocksResponseProto> done)

Description copied from class: DatanodeProtocolProtos.DatanodeProtocolService

rpc reportBadBlocks(.hadoop.hdfs.ReportBadBlocksRequestProto) returns (.hadoop.hdfs.ReportBadBlocksResponseProto);

 Report corrupt blocks at the specified location
 

Specified by:

reportBadBlocks in interface DatanodeProtocolProtos.DatanodeProtocolService.Interface

Specified by:

reportBadBlocks in class DatanodeProtocolProtos.DatanodeProtocolService

commitBlockSynchronization

public void commitBlockSynchronization(com.google.protobuf.RpcController controller,
                              DatanodeProtocolProtos.CommitBlockSynchronizationRequestProto request,
                              com.google.protobuf.RpcCallback<DatanodeProtocolProtos.CommitBlockSynchronizationResponseProto> done)

Description copied from class: DatanodeProtocolProtos.DatanodeProtocolService

rpc commitBlockSynchronization(.hadoop.hdfs.CommitBlockSynchronizationRequestProto) returns (.hadoop.hdfs.CommitBlockSynchronizationResponseProto);

 Commit block synchronization during lease recovery.
 

Specified by:

commitBlockSynchronization in interface DatanodeProtocolProtos.DatanodeProtocolService.Interface

Specified by:

commitBlockSynchronization in class DatanodeProtocolProtos.DatanodeProtocolService