org.apache.hadoop.hdfs.protocol.proto

Class NamenodeProtocolProtos.NamenodeProtocolService.Stub

java.lang.Object

org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.NamenodeProtocolService

org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.NamenodeProtocolService.Stub

All Implemented Interfaces:

com.google.protobuf.Service, NamenodeProtocolProtos.NamenodeProtocolService.Interface

Enclosing class:

NamenodeProtocolProtos.NamenodeProtocolService

public static final class NamenodeProtocolProtos.NamenodeProtocolService.Stub
extends NamenodeProtocolProtos.NamenodeProtocolService
implements NamenodeProtocolProtos.NamenodeProtocolService.Interface

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.NamenodeProtocolService

NamenodeProtocolProtos.NamenodeProtocolService.BlockingInterface, NamenodeProtocolProtos.NamenodeProtocolService.Interface, NamenodeProtocolProtos.NamenodeProtocolService.Stub

Method Summary

Methods

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);

Methods inherited from class org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos.NamenodeProtocolService

callMethod, getDescriptor, getDescriptorForType, getRequestPrototype, getResponsePrototype, newBlockingStub, newReflectiveBlockingService, newReflectiveService, newStub

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getChannel

public com.google.protobuf.RpcChannel getChannel()

getBlocks

public void getBlocks(com.google.protobuf.RpcController controller,
             NamenodeProtocolProtos.GetBlocksRequestProto request,
             com.google.protobuf.RpcCallback<NamenodeProtocolProtos.GetBlocksResponseProto> done)

Description copied from class: 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.
 

Specified by:

getBlocks in interface NamenodeProtocolProtos.NamenodeProtocolService.Interface

Specified by:

getBlocks in class NamenodeProtocolProtos.NamenodeProtocolService

getBlockKeys

public void getBlockKeys(com.google.protobuf.RpcController controller,
                NamenodeProtocolProtos.GetBlockKeysRequestProto request,
                com.google.protobuf.RpcCallback<NamenodeProtocolProtos.GetBlockKeysResponseProto> done)

Description copied from class: NamenodeProtocolProtos.NamenodeProtocolService

rpc getBlockKeys(.hadoop.hdfs.GetBlockKeysRequestProto) returns (.hadoop.hdfs.GetBlockKeysResponseProto);

 Get the current block keys
 

Specified by:

getBlockKeys in interface NamenodeProtocolProtos.NamenodeProtocolService.Interface

Specified by:

getBlockKeys in class NamenodeProtocolProtos.NamenodeProtocolService

getTransactionId

public void getTransactionId(com.google.protobuf.RpcController controller,
                    NamenodeProtocolProtos.GetTransactionIdRequestProto request,
                    com.google.protobuf.RpcCallback<NamenodeProtocolProtos.GetTransactionIdResponseProto> done)

Description copied from class: NamenodeProtocolProtos.NamenodeProtocolService

rpc getTransactionId(.hadoop.hdfs.GetTransactionIdRequestProto) returns (.hadoop.hdfs.GetTransactionIdResponseProto);

 Get the transaction ID of the most recently persisted editlog record
 

Specified by:

getTransactionId in interface NamenodeProtocolProtos.NamenodeProtocolService.Interface

Specified by:

getTransactionId in class NamenodeProtocolProtos.NamenodeProtocolService

getMostRecentCheckpointTxId

public void getMostRecentCheckpointTxId(com.google.protobuf.RpcController controller,
                               NamenodeProtocolProtos.GetMostRecentCheckpointTxIdRequestProto request,
                               com.google.protobuf.RpcCallback<NamenodeProtocolProtos.GetMostRecentCheckpointTxIdResponseProto> done)

Description copied from class: NamenodeProtocolProtos.NamenodeProtocolService

rpc getMostRecentCheckpointTxId(.hadoop.hdfs.GetMostRecentCheckpointTxIdRequestProto) returns (.hadoop.hdfs.GetMostRecentCheckpointTxIdResponseProto);

 Get the transaction ID of the most recently persisted editlog record
 

Specified by:

getMostRecentCheckpointTxId in interface NamenodeProtocolProtos.NamenodeProtocolService.Interface

Specified by:

getMostRecentCheckpointTxId in class NamenodeProtocolProtos.NamenodeProtocolService

rollEditLog

public void rollEditLog(com.google.protobuf.RpcController controller,
               NamenodeProtocolProtos.RollEditLogRequestProto request,
               com.google.protobuf.RpcCallback<NamenodeProtocolProtos.RollEditLogResponseProto> done)

Description copied from class: NamenodeProtocolProtos.NamenodeProtocolService

rpc rollEditLog(.hadoop.hdfs.RollEditLogRequestProto) returns (.hadoop.hdfs.RollEditLogResponseProto);

 Close the current editlog and open a new one for checkpointing purposes
 

Specified by:

rollEditLog in interface NamenodeProtocolProtos.NamenodeProtocolService.Interface

Specified by:

rollEditLog in class NamenodeProtocolProtos.NamenodeProtocolService

versionRequest

public void versionRequest(com.google.protobuf.RpcController controller,
                  HdfsProtos.VersionRequestProto request,
                  com.google.protobuf.RpcCallback<HdfsProtos.VersionResponseProto> done)

Description copied from class: NamenodeProtocolProtos.NamenodeProtocolService

rpc versionRequest(.hadoop.hdfs.VersionRequestProto) returns (.hadoop.hdfs.VersionResponseProto);

 Request info about the version running on this NameNode
 

Specified by:

versionRequest in interface NamenodeProtocolProtos.NamenodeProtocolService.Interface

Specified by:

versionRequest in class NamenodeProtocolProtos.NamenodeProtocolService

errorReport

public void errorReport(com.google.protobuf.RpcController controller,
               NamenodeProtocolProtos.ErrorReportRequestProto request,
               com.google.protobuf.RpcCallback<NamenodeProtocolProtos.ErrorReportResponseProto> done)

Description copied from class: 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.
 

Specified by:

errorReport in interface NamenodeProtocolProtos.NamenodeProtocolService.Interface

Specified by:

errorReport in class NamenodeProtocolProtos.NamenodeProtocolService

registerSubordinateNamenode

public void registerSubordinateNamenode(com.google.protobuf.RpcController controller,
                               NamenodeProtocolProtos.RegisterRequestProto request,
                               com.google.protobuf.RpcCallback<NamenodeProtocolProtos.RegisterResponseProto> done)

Description copied from class: NamenodeProtocolProtos.NamenodeProtocolService

rpc registerSubordinateNamenode(.hadoop.hdfs.RegisterRequestProto) returns (.hadoop.hdfs.RegisterResponseProto);

 Request to register a sub-ordinate namenode
 

Specified by:

registerSubordinateNamenode in interface NamenodeProtocolProtos.NamenodeProtocolService.Interface

Specified by:

registerSubordinateNamenode in class NamenodeProtocolProtos.NamenodeProtocolService

startCheckpoint

public void startCheckpoint(com.google.protobuf.RpcController controller,
                   NamenodeProtocolProtos.StartCheckpointRequestProto request,
                   com.google.protobuf.RpcCallback<NamenodeProtocolProtos.StartCheckpointResponseProto> done)

Description copied from class: NamenodeProtocolProtos.NamenodeProtocolService

rpc startCheckpoint(.hadoop.hdfs.StartCheckpointRequestProto) returns (.hadoop.hdfs.StartCheckpointResponseProto);

 Request to start a checkpoint. 
 

Specified by:

startCheckpoint in interface NamenodeProtocolProtos.NamenodeProtocolService.Interface

Specified by:

startCheckpoint in class NamenodeProtocolProtos.NamenodeProtocolService

endCheckpoint

public void endCheckpoint(com.google.protobuf.RpcController controller,
                 NamenodeProtocolProtos.EndCheckpointRequestProto request,
                 com.google.protobuf.RpcCallback<NamenodeProtocolProtos.EndCheckpointResponseProto> done)

Description copied from class: NamenodeProtocolProtos.NamenodeProtocolService

rpc endCheckpoint(.hadoop.hdfs.EndCheckpointRequestProto) returns (.hadoop.hdfs.EndCheckpointResponseProto);

 End of finalize the previously started checkpoint
 

Specified by:

endCheckpoint in interface NamenodeProtocolProtos.NamenodeProtocolService.Interface

Specified by:

endCheckpoint in class NamenodeProtocolProtos.NamenodeProtocolService

getEditLogManifest

public void getEditLogManifest(com.google.protobuf.RpcController controller,
                      NamenodeProtocolProtos.GetEditLogManifestRequestProto request,
                      com.google.protobuf.RpcCallback<NamenodeProtocolProtos.GetEditLogManifestResponseProto> done)

Description copied from class: NamenodeProtocolProtos.NamenodeProtocolService

rpc getEditLogManifest(.hadoop.hdfs.GetEditLogManifestRequestProto) returns (.hadoop.hdfs.GetEditLogManifestResponseProto);

 Get editlog manifests from the active namenode for all the editlogs
 

Specified by:

getEditLogManifest in interface NamenodeProtocolProtos.NamenodeProtocolService.Interface

Specified by:

getEditLogManifest in class NamenodeProtocolProtos.NamenodeProtocolService