public static final class NamenodeProtocolProtos.NamenodeProtocolService.Stub extends NamenodeProtocolProtos.NamenodeProtocolService implements NamenodeProtocolProtos.NamenodeProtocolService.Interface
NamenodeProtocolProtos.NamenodeProtocolService.BlockingInterface, NamenodeProtocolProtos.NamenodeProtocolService.Interface, NamenodeProtocolProtos.NamenodeProtocolService.Stub
Modifier and Type | Method and Description |
---|---|
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); |
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); |
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); |
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); |
com.google.protobuf.RpcChannel |
getChannel() |
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); |
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); |
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); |
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); |
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); |
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); |
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 getBlocks(com.google.protobuf.RpcController controller, NamenodeProtocolProtos.GetBlocksRequestProto request, com.google.protobuf.RpcCallback<NamenodeProtocolProtos.GetBlocksResponseProto> done)
NamenodeProtocolProtos.NamenodeProtocolService
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.
getBlocks
in interface NamenodeProtocolProtos.NamenodeProtocolService.Interface
getBlocks
in class NamenodeProtocolProtos.NamenodeProtocolService
public void getBlockKeys(com.google.protobuf.RpcController controller, NamenodeProtocolProtos.GetBlockKeysRequestProto request, com.google.protobuf.RpcCallback<NamenodeProtocolProtos.GetBlockKeysResponseProto> done)
NamenodeProtocolProtos.NamenodeProtocolService
rpc getBlockKeys(.hadoop.hdfs.GetBlockKeysRequestProto) returns (.hadoop.hdfs.GetBlockKeysResponseProto);
Get the current block keys
getBlockKeys
in interface NamenodeProtocolProtos.NamenodeProtocolService.Interface
getBlockKeys
in class NamenodeProtocolProtos.NamenodeProtocolService
public void getTransactionId(com.google.protobuf.RpcController controller, NamenodeProtocolProtos.GetTransactionIdRequestProto request, com.google.protobuf.RpcCallback<NamenodeProtocolProtos.GetTransactionIdResponseProto> done)
NamenodeProtocolProtos.NamenodeProtocolService
rpc getTransactionId(.hadoop.hdfs.GetTransactionIdRequestProto) returns (.hadoop.hdfs.GetTransactionIdResponseProto);
Get the transaction ID of the most recently persisted editlog record
getTransactionId
in interface NamenodeProtocolProtos.NamenodeProtocolService.Interface
getTransactionId
in class NamenodeProtocolProtos.NamenodeProtocolService
public void getMostRecentCheckpointTxId(com.google.protobuf.RpcController controller, NamenodeProtocolProtos.GetMostRecentCheckpointTxIdRequestProto request, com.google.protobuf.RpcCallback<NamenodeProtocolProtos.GetMostRecentCheckpointTxIdResponseProto> done)
NamenodeProtocolProtos.NamenodeProtocolService
rpc getMostRecentCheckpointTxId(.hadoop.hdfs.GetMostRecentCheckpointTxIdRequestProto) returns (.hadoop.hdfs.GetMostRecentCheckpointTxIdResponseProto);
Get the transaction ID of the most recently persisted editlog record
getMostRecentCheckpointTxId
in interface NamenodeProtocolProtos.NamenodeProtocolService.Interface
getMostRecentCheckpointTxId
in class NamenodeProtocolProtos.NamenodeProtocolService
public void rollEditLog(com.google.protobuf.RpcController controller, NamenodeProtocolProtos.RollEditLogRequestProto request, com.google.protobuf.RpcCallback<NamenodeProtocolProtos.RollEditLogResponseProto> done)
NamenodeProtocolProtos.NamenodeProtocolService
rpc rollEditLog(.hadoop.hdfs.RollEditLogRequestProto) returns (.hadoop.hdfs.RollEditLogResponseProto);
Close the current editlog and open a new one for checkpointing purposes
rollEditLog
in interface NamenodeProtocolProtos.NamenodeProtocolService.Interface
rollEditLog
in class NamenodeProtocolProtos.NamenodeProtocolService
public void versionRequest(com.google.protobuf.RpcController controller, HdfsProtos.VersionRequestProto request, com.google.protobuf.RpcCallback<HdfsProtos.VersionResponseProto> done)
NamenodeProtocolProtos.NamenodeProtocolService
rpc versionRequest(.hadoop.hdfs.VersionRequestProto) returns (.hadoop.hdfs.VersionResponseProto);
Request info about the version running on this NameNode
versionRequest
in interface NamenodeProtocolProtos.NamenodeProtocolService.Interface
versionRequest
in class NamenodeProtocolProtos.NamenodeProtocolService
public void errorReport(com.google.protobuf.RpcController controller, NamenodeProtocolProtos.ErrorReportRequestProto request, com.google.protobuf.RpcCallback<NamenodeProtocolProtos.ErrorReportResponseProto> done)
NamenodeProtocolProtos.NamenodeProtocolService
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.
errorReport
in interface NamenodeProtocolProtos.NamenodeProtocolService.Interface
errorReport
in class NamenodeProtocolProtos.NamenodeProtocolService
public void registerSubordinateNamenode(com.google.protobuf.RpcController controller, NamenodeProtocolProtos.RegisterRequestProto request, com.google.protobuf.RpcCallback<NamenodeProtocolProtos.RegisterResponseProto> done)
NamenodeProtocolProtos.NamenodeProtocolService
rpc registerSubordinateNamenode(.hadoop.hdfs.RegisterRequestProto) returns (.hadoop.hdfs.RegisterResponseProto);
Request to register a sub-ordinate namenode
registerSubordinateNamenode
in interface NamenodeProtocolProtos.NamenodeProtocolService.Interface
registerSubordinateNamenode
in class NamenodeProtocolProtos.NamenodeProtocolService
public void startCheckpoint(com.google.protobuf.RpcController controller, NamenodeProtocolProtos.StartCheckpointRequestProto request, com.google.protobuf.RpcCallback<NamenodeProtocolProtos.StartCheckpointResponseProto> done)
NamenodeProtocolProtos.NamenodeProtocolService
rpc startCheckpoint(.hadoop.hdfs.StartCheckpointRequestProto) returns (.hadoop.hdfs.StartCheckpointResponseProto);
Request to start a checkpoint.
startCheckpoint
in interface NamenodeProtocolProtos.NamenodeProtocolService.Interface
startCheckpoint
in class NamenodeProtocolProtos.NamenodeProtocolService
public void endCheckpoint(com.google.protobuf.RpcController controller, NamenodeProtocolProtos.EndCheckpointRequestProto request, com.google.protobuf.RpcCallback<NamenodeProtocolProtos.EndCheckpointResponseProto> done)
NamenodeProtocolProtos.NamenodeProtocolService
rpc endCheckpoint(.hadoop.hdfs.EndCheckpointRequestProto) returns (.hadoop.hdfs.EndCheckpointResponseProto);
End of finalize the previously started checkpoint
endCheckpoint
in interface NamenodeProtocolProtos.NamenodeProtocolService.Interface
endCheckpoint
in class NamenodeProtocolProtos.NamenodeProtocolService
public void getEditLogManifest(com.google.protobuf.RpcController controller, NamenodeProtocolProtos.GetEditLogManifestRequestProto request, com.google.protobuf.RpcCallback<NamenodeProtocolProtos.GetEditLogManifestResponseProto> done)
NamenodeProtocolProtos.NamenodeProtocolService
rpc getEditLogManifest(.hadoop.hdfs.GetEditLogManifestRequestProto) returns (.hadoop.hdfs.GetEditLogManifestResponseProto);
Get editlog manifests from the active namenode for all the editlogs
getEditLogManifest
in interface NamenodeProtocolProtos.NamenodeProtocolService.Interface
getEditLogManifest
in class NamenodeProtocolProtos.NamenodeProtocolService
Copyright © 2013 Apache Software Foundation. All rights reserved.