public static final class DatanodeProtocolProtos.DatanodeProtocolService.Stub extends DatanodeProtocolProtos.DatanodeProtocolService implements DatanodeProtocolProtos.DatanodeProtocolService.Interface
DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface, DatanodeProtocolProtos.DatanodeProtocolService.Interface, DatanodeProtocolProtos.DatanodeProtocolService.Stub
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); |
callMethod, getDescriptor, getDescriptorForType, getRequestPrototype, getResponsePrototype, newBlockingStub, newReflectiveBlockingService, newReflectiveService, newStub
public com.google.protobuf.RpcChannel getChannel()
public void registerDatanode(com.google.protobuf.RpcController controller, DatanodeProtocolProtos.RegisterDatanodeRequestProto request, com.google.protobuf.RpcCallback<DatanodeProtocolProtos.RegisterDatanodeResponseProto> done)
DatanodeProtocolProtos.DatanodeProtocolService
rpc registerDatanode(.hadoop.hdfs.RegisterDatanodeRequestProto) returns (.hadoop.hdfs.RegisterDatanodeResponseProto);
Register a datanode at a namenode
registerDatanode
in interface DatanodeProtocolProtos.DatanodeProtocolService.Interface
registerDatanode
in class DatanodeProtocolProtos.DatanodeProtocolService
public void sendHeartbeat(com.google.protobuf.RpcController controller, DatanodeProtocolProtos.HeartbeatRequestProto request, com.google.protobuf.RpcCallback<DatanodeProtocolProtos.HeartbeatResponseProto> done)
DatanodeProtocolProtos.DatanodeProtocolService
rpc sendHeartbeat(.hadoop.hdfs.HeartbeatRequestProto) returns (.hadoop.hdfs.HeartbeatResponseProto);
Send heartbeat from datanode to namenode
sendHeartbeat
in interface DatanodeProtocolProtos.DatanodeProtocolService.Interface
sendHeartbeat
in class DatanodeProtocolProtos.DatanodeProtocolService
public void blockReport(com.google.protobuf.RpcController controller, DatanodeProtocolProtos.BlockReportRequestProto request, com.google.protobuf.RpcCallback<DatanodeProtocolProtos.BlockReportResponseProto> done)
DatanodeProtocolProtos.DatanodeProtocolService
rpc blockReport(.hadoop.hdfs.BlockReportRequestProto) returns (.hadoop.hdfs.BlockReportResponseProto);
Report blocks at a given datanode to the namenode
blockReport
in interface DatanodeProtocolProtos.DatanodeProtocolService.Interface
blockReport
in class DatanodeProtocolProtos.DatanodeProtocolService
public void blockReceivedAndDeleted(com.google.protobuf.RpcController controller, DatanodeProtocolProtos.BlockReceivedAndDeletedRequestProto request, com.google.protobuf.RpcCallback<DatanodeProtocolProtos.BlockReceivedAndDeletedResponseProto> done)
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.
blockReceivedAndDeleted
in interface DatanodeProtocolProtos.DatanodeProtocolService.Interface
blockReceivedAndDeleted
in class DatanodeProtocolProtos.DatanodeProtocolService
public void errorReport(com.google.protobuf.RpcController controller, DatanodeProtocolProtos.ErrorReportRequestProto request, com.google.protobuf.RpcCallback<DatanodeProtocolProtos.ErrorReportResponseProto> done)
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.
errorReport
in interface DatanodeProtocolProtos.DatanodeProtocolService.Interface
errorReport
in class DatanodeProtocolProtos.DatanodeProtocolService
public void versionRequest(com.google.protobuf.RpcController controller, HdfsProtos.VersionRequestProto request, com.google.protobuf.RpcCallback<HdfsProtos.VersionResponseProto> done)
DatanodeProtocolProtos.DatanodeProtocolService
rpc versionRequest(.hadoop.hdfs.VersionRequestProto) returns (.hadoop.hdfs.VersionResponseProto);
Request the version
versionRequest
in interface DatanodeProtocolProtos.DatanodeProtocolService.Interface
versionRequest
in class DatanodeProtocolProtos.DatanodeProtocolService
public void reportBadBlocks(com.google.protobuf.RpcController controller, DatanodeProtocolProtos.ReportBadBlocksRequestProto request, com.google.protobuf.RpcCallback<DatanodeProtocolProtos.ReportBadBlocksResponseProto> done)
DatanodeProtocolProtos.DatanodeProtocolService
rpc reportBadBlocks(.hadoop.hdfs.ReportBadBlocksRequestProto) returns (.hadoop.hdfs.ReportBadBlocksResponseProto);
Report corrupt blocks at the specified location
reportBadBlocks
in interface DatanodeProtocolProtos.DatanodeProtocolService.Interface
reportBadBlocks
in class DatanodeProtocolProtos.DatanodeProtocolService
public void commitBlockSynchronization(com.google.protobuf.RpcController controller, DatanodeProtocolProtos.CommitBlockSynchronizationRequestProto request, com.google.protobuf.RpcCallback<DatanodeProtocolProtos.CommitBlockSynchronizationResponseProto> done)
DatanodeProtocolProtos.DatanodeProtocolService
rpc commitBlockSynchronization(.hadoop.hdfs.CommitBlockSynchronizationRequestProto) returns (.hadoop.hdfs.CommitBlockSynchronizationResponseProto);
Commit block synchronization during lease recovery.
commitBlockSynchronization
in interface DatanodeProtocolProtos.DatanodeProtocolService.Interface
commitBlockSynchronization
in class DatanodeProtocolProtos.DatanodeProtocolService
Copyright © 2013 Apache Software Foundation. All rights reserved.