public static interface DatanodeProtocolProtos.DatanodeProtocolService.Interface
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); |
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); |
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);
Register a datanode at a namenode
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);
Send heartbeat from datanode to namenode
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);
Report blocks at a given datanode to the namenode
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);
Incremental block report from the DN. This contains info about recently received and deleted blocks, as well as when blocks start being received.
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);
Report from a datanode of an error to the active namenode. Used for debugging.
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);
Request the version
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);
Report corrupt blocks at the specified location
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);
Commit block synchronization during lease recovery.
Copyright © 2013 Apache Software Foundation. All rights reserved.