public abstract static class DatanodeProtocolProtos.DatanodeProtocolService extends Object implements com.google.protobuf.Service
hadoop.hdfs.DatanodeProtocolService
Protocol used from datanode to the namenode See the request and response for details of rpc call.
Modifier and Type | Class and Description |
---|---|
static interface |
DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface |
static interface |
DatanodeProtocolProtos.DatanodeProtocolService.Interface |
static class |
DatanodeProtocolProtos.DatanodeProtocolService.Stub |
Modifier | Constructor and Description |
---|---|
protected |
DatanodeProtocolProtos.DatanodeProtocolService() |
Modifier and Type | Method and Description |
---|---|
abstract 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); |
abstract 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 |
callMethod(com.google.protobuf.Descriptors.MethodDescriptor method,
com.google.protobuf.RpcController controller,
com.google.protobuf.Message request,
com.google.protobuf.RpcCallback<com.google.protobuf.Message> done) |
abstract 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); |
abstract 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); |
static com.google.protobuf.Descriptors.ServiceDescriptor |
getDescriptor() |
com.google.protobuf.Descriptors.ServiceDescriptor |
getDescriptorForType() |
com.google.protobuf.Message |
getRequestPrototype(com.google.protobuf.Descriptors.MethodDescriptor method) |
com.google.protobuf.Message |
getResponsePrototype(com.google.protobuf.Descriptors.MethodDescriptor method) |
static DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface |
newBlockingStub(com.google.protobuf.BlockingRpcChannel channel) |
static com.google.protobuf.BlockingService |
newReflectiveBlockingService(DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface impl) |
static com.google.protobuf.Service |
newReflectiveService(DatanodeProtocolProtos.DatanodeProtocolService.Interface impl) |
static DatanodeProtocolProtos.DatanodeProtocolService.Stub |
newStub(com.google.protobuf.RpcChannel channel) |
abstract 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); |
abstract 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); |
abstract 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); |
abstract 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); |
protected DatanodeProtocolProtos.DatanodeProtocolService()
public static com.google.protobuf.Service newReflectiveService(DatanodeProtocolProtos.DatanodeProtocolService.Interface impl)
public static com.google.protobuf.BlockingService newReflectiveBlockingService(DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface impl)
public abstract 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
public abstract 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
public abstract 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
public abstract 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.
public abstract 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.
public abstract 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
public abstract 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
public abstract 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.
public static final com.google.protobuf.Descriptors.ServiceDescriptor getDescriptor()
public final com.google.protobuf.Descriptors.ServiceDescriptor getDescriptorForType()
getDescriptorForType
in interface com.google.protobuf.Service
public final void callMethod(com.google.protobuf.Descriptors.MethodDescriptor method, com.google.protobuf.RpcController controller, com.google.protobuf.Message request, com.google.protobuf.RpcCallback<com.google.protobuf.Message> done)
callMethod
in interface com.google.protobuf.Service
public final com.google.protobuf.Message getRequestPrototype(com.google.protobuf.Descriptors.MethodDescriptor method)
getRequestPrototype
in interface com.google.protobuf.Service
public final com.google.protobuf.Message getResponsePrototype(com.google.protobuf.Descriptors.MethodDescriptor method)
getResponsePrototype
in interface com.google.protobuf.Service
public static DatanodeProtocolProtos.DatanodeProtocolService.Stub newStub(com.google.protobuf.RpcChannel channel)
public static DatanodeProtocolProtos.DatanodeProtocolService.BlockingInterface newBlockingStub(com.google.protobuf.BlockingRpcChannel channel)
Copyright © 2013 Apache Software Foundation. All rights reserved.