public abstract static class NamenodeProtocolProtos.NamenodeProtocolService extends Object implements com.google.protobuf.Service
hadoop.hdfs.NamenodeProtocolService
Protocol used by the sub-ordinate namenode to send requests the active/primary namenode. See the request and response for details of rpc call.
Modifier and Type | Class and Description |
---|---|
static interface |
NamenodeProtocolProtos.NamenodeProtocolService.BlockingInterface |
static interface |
NamenodeProtocolProtos.NamenodeProtocolService.Interface |
static class |
NamenodeProtocolProtos.NamenodeProtocolService.Stub |
Modifier | Constructor and Description |
---|---|
protected |
NamenodeProtocolProtos.NamenodeProtocolService() |
Modifier and Type | Method and Description |
---|---|
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 |
endCheckpoint(com.google.protobuf.RpcController controller,
NamenodeProtocolProtos.EndCheckpointRequestProto request,
com.google.protobuf.RpcCallback<NamenodeProtocolProtos.EndCheckpointResponseProto> done)
rpc endCheckpoint(.hadoop.hdfs.EndCheckpointRequestProto) returns (.hadoop.hdfs.EndCheckpointResponseProto); |
abstract void |
errorReport(com.google.protobuf.RpcController controller,
NamenodeProtocolProtos.ErrorReportRequestProto request,
com.google.protobuf.RpcCallback<NamenodeProtocolProtos.ErrorReportResponseProto> done)
rpc errorReport(.hadoop.hdfs.ErrorReportRequestProto) returns (.hadoop.hdfs.ErrorReportResponseProto); |
abstract void |
getBlockKeys(com.google.protobuf.RpcController controller,
NamenodeProtocolProtos.GetBlockKeysRequestProto request,
com.google.protobuf.RpcCallback<NamenodeProtocolProtos.GetBlockKeysResponseProto> done)
rpc getBlockKeys(.hadoop.hdfs.GetBlockKeysRequestProto) returns (.hadoop.hdfs.GetBlockKeysResponseProto); |
abstract void |
getBlocks(com.google.protobuf.RpcController controller,
NamenodeProtocolProtos.GetBlocksRequestProto request,
com.google.protobuf.RpcCallback<NamenodeProtocolProtos.GetBlocksResponseProto> done)
rpc getBlocks(.hadoop.hdfs.GetBlocksRequestProto) returns (.hadoop.hdfs.GetBlocksResponseProto); |
static com.google.protobuf.Descriptors.ServiceDescriptor |
getDescriptor() |
com.google.protobuf.Descriptors.ServiceDescriptor |
getDescriptorForType() |
abstract void |
getEditLogManifest(com.google.protobuf.RpcController controller,
NamenodeProtocolProtos.GetEditLogManifestRequestProto request,
com.google.protobuf.RpcCallback<NamenodeProtocolProtos.GetEditLogManifestResponseProto> done)
rpc getEditLogManifest(.hadoop.hdfs.GetEditLogManifestRequestProto) returns (.hadoop.hdfs.GetEditLogManifestResponseProto); |
abstract void |
getMostRecentCheckpointTxId(com.google.protobuf.RpcController controller,
NamenodeProtocolProtos.GetMostRecentCheckpointTxIdRequestProto request,
com.google.protobuf.RpcCallback<NamenodeProtocolProtos.GetMostRecentCheckpointTxIdResponseProto> done)
rpc getMostRecentCheckpointTxId(.hadoop.hdfs.GetMostRecentCheckpointTxIdRequestProto) returns (.hadoop.hdfs.GetMostRecentCheckpointTxIdResponseProto); |
com.google.protobuf.Message |
getRequestPrototype(com.google.protobuf.Descriptors.MethodDescriptor method) |
com.google.protobuf.Message |
getResponsePrototype(com.google.protobuf.Descriptors.MethodDescriptor method) |
abstract void |
getTransactionId(com.google.protobuf.RpcController controller,
NamenodeProtocolProtos.GetTransactionIdRequestProto request,
com.google.protobuf.RpcCallback<NamenodeProtocolProtos.GetTransactionIdResponseProto> done)
rpc getTransactionId(.hadoop.hdfs.GetTransactionIdRequestProto) returns (.hadoop.hdfs.GetTransactionIdResponseProto); |
static NamenodeProtocolProtos.NamenodeProtocolService.BlockingInterface |
newBlockingStub(com.google.protobuf.BlockingRpcChannel channel) |
static com.google.protobuf.BlockingService |
newReflectiveBlockingService(NamenodeProtocolProtos.NamenodeProtocolService.BlockingInterface impl) |
static com.google.protobuf.Service |
newReflectiveService(NamenodeProtocolProtos.NamenodeProtocolService.Interface impl) |
static NamenodeProtocolProtos.NamenodeProtocolService.Stub |
newStub(com.google.protobuf.RpcChannel channel) |
abstract void |
registerSubordinateNamenode(com.google.protobuf.RpcController controller,
NamenodeProtocolProtos.RegisterRequestProto request,
com.google.protobuf.RpcCallback<NamenodeProtocolProtos.RegisterResponseProto> done)
rpc registerSubordinateNamenode(.hadoop.hdfs.RegisterRequestProto) returns (.hadoop.hdfs.RegisterResponseProto); |
abstract void |
rollEditLog(com.google.protobuf.RpcController controller,
NamenodeProtocolProtos.RollEditLogRequestProto request,
com.google.protobuf.RpcCallback<NamenodeProtocolProtos.RollEditLogResponseProto> done)
rpc rollEditLog(.hadoop.hdfs.RollEditLogRequestProto) returns (.hadoop.hdfs.RollEditLogResponseProto); |
abstract void |
startCheckpoint(com.google.protobuf.RpcController controller,
NamenodeProtocolProtos.StartCheckpointRequestProto request,
com.google.protobuf.RpcCallback<NamenodeProtocolProtos.StartCheckpointResponseProto> done)
rpc startCheckpoint(.hadoop.hdfs.StartCheckpointRequestProto) returns (.hadoop.hdfs.StartCheckpointResponseProto); |
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 NamenodeProtocolProtos.NamenodeProtocolService()
public static com.google.protobuf.Service newReflectiveService(NamenodeProtocolProtos.NamenodeProtocolService.Interface impl)
public static com.google.protobuf.BlockingService newReflectiveBlockingService(NamenodeProtocolProtos.NamenodeProtocolService.BlockingInterface impl)
public abstract void getBlocks(com.google.protobuf.RpcController controller, NamenodeProtocolProtos.GetBlocksRequestProto request, com.google.protobuf.RpcCallback<NamenodeProtocolProtos.GetBlocksResponseProto> done)
rpc getBlocks(.hadoop.hdfs.GetBlocksRequestProto) returns (.hadoop.hdfs.GetBlocksResponseProto);
Get list of blocks for a given datanode with length of blocks adding up to given size.
public abstract void getBlockKeys(com.google.protobuf.RpcController controller, NamenodeProtocolProtos.GetBlockKeysRequestProto request, com.google.protobuf.RpcCallback<NamenodeProtocolProtos.GetBlockKeysResponseProto> done)
rpc getBlockKeys(.hadoop.hdfs.GetBlockKeysRequestProto) returns (.hadoop.hdfs.GetBlockKeysResponseProto);
Get the current block keys
public abstract void getTransactionId(com.google.protobuf.RpcController controller, NamenodeProtocolProtos.GetTransactionIdRequestProto request, com.google.protobuf.RpcCallback<NamenodeProtocolProtos.GetTransactionIdResponseProto> done)
rpc getTransactionId(.hadoop.hdfs.GetTransactionIdRequestProto) returns (.hadoop.hdfs.GetTransactionIdResponseProto);
Get the transaction ID of the most recently persisted editlog record
public abstract void getMostRecentCheckpointTxId(com.google.protobuf.RpcController controller, NamenodeProtocolProtos.GetMostRecentCheckpointTxIdRequestProto request, com.google.protobuf.RpcCallback<NamenodeProtocolProtos.GetMostRecentCheckpointTxIdResponseProto> done)
rpc getMostRecentCheckpointTxId(.hadoop.hdfs.GetMostRecentCheckpointTxIdRequestProto) returns (.hadoop.hdfs.GetMostRecentCheckpointTxIdResponseProto);
Get the transaction ID of the most recently persisted editlog record
public abstract void rollEditLog(com.google.protobuf.RpcController controller, NamenodeProtocolProtos.RollEditLogRequestProto request, com.google.protobuf.RpcCallback<NamenodeProtocolProtos.RollEditLogResponseProto> done)
rpc rollEditLog(.hadoop.hdfs.RollEditLogRequestProto) returns (.hadoop.hdfs.RollEditLogResponseProto);
Close the current editlog and open a new one for checkpointing purposes
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 info about the version running on this NameNode
public abstract void errorReport(com.google.protobuf.RpcController controller, NamenodeProtocolProtos.ErrorReportRequestProto request, com.google.protobuf.RpcCallback<NamenodeProtocolProtos.ErrorReportResponseProto> done)
rpc errorReport(.hadoop.hdfs.ErrorReportRequestProto) returns (.hadoop.hdfs.ErrorReportResponseProto);
Report from a sub-ordinate namenode of an error to the active namenode. Active namenode may decide to unregister the reporting namenode depending on the error.
public abstract void registerSubordinateNamenode(com.google.protobuf.RpcController controller, NamenodeProtocolProtos.RegisterRequestProto request, com.google.protobuf.RpcCallback<NamenodeProtocolProtos.RegisterResponseProto> done)
rpc registerSubordinateNamenode(.hadoop.hdfs.RegisterRequestProto) returns (.hadoop.hdfs.RegisterResponseProto);
Request to register a sub-ordinate namenode
public abstract void startCheckpoint(com.google.protobuf.RpcController controller, NamenodeProtocolProtos.StartCheckpointRequestProto request, com.google.protobuf.RpcCallback<NamenodeProtocolProtos.StartCheckpointResponseProto> done)
rpc startCheckpoint(.hadoop.hdfs.StartCheckpointRequestProto) returns (.hadoop.hdfs.StartCheckpointResponseProto);
Request to start a checkpoint.
public abstract void endCheckpoint(com.google.protobuf.RpcController controller, NamenodeProtocolProtos.EndCheckpointRequestProto request, com.google.protobuf.RpcCallback<NamenodeProtocolProtos.EndCheckpointResponseProto> done)
rpc endCheckpoint(.hadoop.hdfs.EndCheckpointRequestProto) returns (.hadoop.hdfs.EndCheckpointResponseProto);
End of finalize the previously started checkpoint
public abstract void getEditLogManifest(com.google.protobuf.RpcController controller, NamenodeProtocolProtos.GetEditLogManifestRequestProto request, com.google.protobuf.RpcCallback<NamenodeProtocolProtos.GetEditLogManifestResponseProto> done)
rpc getEditLogManifest(.hadoop.hdfs.GetEditLogManifestRequestProto) returns (.hadoop.hdfs.GetEditLogManifestResponseProto);
Get editlog manifests from the active namenode for all the editlogs
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 NamenodeProtocolProtos.NamenodeProtocolService.Stub newStub(com.google.protobuf.RpcChannel channel)
public static NamenodeProtocolProtos.NamenodeProtocolService.BlockingInterface newBlockingStub(com.google.protobuf.BlockingRpcChannel channel)
Copyright © 2013 Apache Software Foundation. All rights reserved.