org.apache.hadoop.hdfs.protocolPB

Class ClientNamenodeProtocolServerSideTranslatorPB

java.lang.Object

org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolServerSideTranslatorPB

All Implemented Interfaces:

ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface, ClientNamenodeProtocolPB

@InterfaceAudience.Private
@InterfaceStability.Stable
public class ClientNamenodeProtocolServerSideTranslatorPB
extends Object
implements ClientNamenodeProtocolPB

This class is used on the server side. Calls come across the wire for the for protocol ClientNamenodeProtocolPB. This class translates the PB data types to the native data types used inside the NN as specified in the generic ClientProtocol.

Constructor Summary

Constructors

Constructor and Description
ClientNamenodeProtocolServerSideTranslatorPB(ClientProtocol server) Constructor

Method Summary

Methods

Modifier and Type	Method and Description
ClientNamenodeProtocolProtos.AbandonBlockResponseProto	abandonBlock(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.AbandonBlockRequestProto req)
ClientNamenodeProtocolProtos.AddBlockResponseProto	addBlock(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.AddBlockRequestProto req)
ClientNamenodeProtocolProtos.AllowSnapshotResponseProto	allowSnapshot(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.AllowSnapshotRequestProto req)
ClientNamenodeProtocolProtos.AppendResponseProto	append(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.AppendRequestProto req)
SecurityProtos.CancelDelegationTokenResponseProto	cancelDelegationToken(com.google.protobuf.RpcController controller, SecurityProtos.CancelDelegationTokenRequestProto req)
ClientNamenodeProtocolProtos.CompleteResponseProto	complete(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.CompleteRequestProto req)
ClientNamenodeProtocolProtos.ConcatResponseProto	concat(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.ConcatRequestProto req)
ClientNamenodeProtocolProtos.CreateResponseProto	create(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.CreateRequestProto req)
ClientNamenodeProtocolProtos.CreateSnapshotResponseProto	createSnapshot(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.CreateSnapshotRequestProto req)
ClientNamenodeProtocolProtos.CreateSymlinkResponseProto	createSymlink(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.CreateSymlinkRequestProto req)
ClientNamenodeProtocolProtos.DeleteResponseProto	delete(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.DeleteRequestProto req)
ClientNamenodeProtocolProtos.DeleteSnapshotResponseProto	deleteSnapshot(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.DeleteSnapshotRequestProto req)
ClientNamenodeProtocolProtos.DisallowSnapshotResponseProto	disallowSnapshot(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.DisallowSnapshotRequestProto req)
ClientNamenodeProtocolProtos.FinalizeUpgradeResponseProto	finalizeUpgrade(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.FinalizeUpgradeRequestProto req)
ClientNamenodeProtocolProtos.FsyncResponseProto	fsync(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.FsyncRequestProto req)
ClientNamenodeProtocolProtos.GetAdditionalDatanodeResponseProto	getAdditionalDatanode(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.GetAdditionalDatanodeRequestProto req)
ClientNamenodeProtocolProtos.GetBlockLocationsResponseProto	getBlockLocations(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.GetBlockLocationsRequestProto req)
ClientNamenodeProtocolProtos.GetContentSummaryResponseProto	getContentSummary(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.GetContentSummaryRequestProto req)
ClientNamenodeProtocolProtos.GetDataEncryptionKeyResponseProto	getDataEncryptionKey(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.GetDataEncryptionKeyRequestProto request)
ClientNamenodeProtocolProtos.GetDatanodeReportResponseProto	getDatanodeReport(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.GetDatanodeReportRequestProto req)
SecurityProtos.GetDelegationTokenResponseProto	getDelegationToken(com.google.protobuf.RpcController controller, SecurityProtos.GetDelegationTokenRequestProto req)
ClientNamenodeProtocolProtos.GetFileInfoResponseProto	getFileInfo(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.GetFileInfoRequestProto req)
ClientNamenodeProtocolProtos.GetFileLinkInfoResponseProto	getFileLinkInfo(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.GetFileLinkInfoRequestProto req)
ClientNamenodeProtocolProtos.GetFsStatsResponseProto	getFsStats(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.GetFsStatusRequestProto req)
ClientNamenodeProtocolProtos.GetLinkTargetResponseProto	getLinkTarget(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.GetLinkTargetRequestProto req)
ClientNamenodeProtocolProtos.GetListingResponseProto	getListing(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.GetListingRequestProto req)
ClientNamenodeProtocolProtos.GetPreferredBlockSizeResponseProto	getPreferredBlockSize(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.GetPreferredBlockSizeRequestProto req)
ClientNamenodeProtocolProtos.GetServerDefaultsResponseProto	getServerDefaults(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.GetServerDefaultsRequestProto req)
ClientNamenodeProtocolProtos.GetSnapshotDiffReportResponseProto	getSnapshotDiffReport(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.GetSnapshotDiffReportRequestProto request)
ClientNamenodeProtocolProtos.GetSnapshottableDirListingResponseProto	getSnapshottableDirListing(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.GetSnapshottableDirListingRequestProto request)
ClientNamenodeProtocolProtos.IsFileClosedResponseProto	isFileClosed(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.IsFileClosedRequestProto request)
ClientNamenodeProtocolProtos.ListCorruptFileBlocksResponseProto	listCorruptFileBlocks(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.ListCorruptFileBlocksRequestProto req)
ClientNamenodeProtocolProtos.MetaSaveResponseProto	metaSave(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.MetaSaveRequestProto req)
ClientNamenodeProtocolProtos.MkdirsResponseProto	mkdirs(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.MkdirsRequestProto req)
ClientNamenodeProtocolProtos.RecoverLeaseResponseProto	recoverLease(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.RecoverLeaseRequestProto req)
ClientNamenodeProtocolProtos.RefreshNodesResponseProto	refreshNodes(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.RefreshNodesRequestProto req)
ClientNamenodeProtocolProtos.RenameResponseProto	rename(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.RenameRequestProto req)
ClientNamenodeProtocolProtos.Rename2ResponseProto	rename2(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.Rename2RequestProto req)
ClientNamenodeProtocolProtos.RenameSnapshotResponseProto	renameSnapshot(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.RenameSnapshotRequestProto request)
SecurityProtos.RenewDelegationTokenResponseProto	renewDelegationToken(com.google.protobuf.RpcController controller, SecurityProtos.RenewDelegationTokenRequestProto req)
ClientNamenodeProtocolProtos.RenewLeaseResponseProto	renewLease(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.RenewLeaseRequestProto req)
ClientNamenodeProtocolProtos.ReportBadBlocksResponseProto	reportBadBlocks(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.ReportBadBlocksRequestProto req)
ClientNamenodeProtocolProtos.RestoreFailedStorageResponseProto	restoreFailedStorage(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.RestoreFailedStorageRequestProto req)
ClientNamenodeProtocolProtos.RollEditsResponseProto	rollEdits(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.RollEditsRequestProto request)
ClientNamenodeProtocolProtos.SaveNamespaceResponseProto	saveNamespace(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.SaveNamespaceRequestProto req)
ClientNamenodeProtocolProtos.SetBalancerBandwidthResponseProto	setBalancerBandwidth(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.SetBalancerBandwidthRequestProto req)
ClientNamenodeProtocolProtos.SetOwnerResponseProto	setOwner(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.SetOwnerRequestProto req)
ClientNamenodeProtocolProtos.SetPermissionResponseProto	setPermission(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.SetPermissionRequestProto req)
ClientNamenodeProtocolProtos.SetQuotaResponseProto	setQuota(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.SetQuotaRequestProto req)
ClientNamenodeProtocolProtos.SetReplicationResponseProto	setReplication(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.SetReplicationRequestProto req)
ClientNamenodeProtocolProtos.SetSafeModeResponseProto	setSafeMode(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.SetSafeModeRequestProto req)
ClientNamenodeProtocolProtos.SetTimesResponseProto	setTimes(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.SetTimesRequestProto req)
ClientNamenodeProtocolProtos.UpdateBlockForPipelineResponseProto	updateBlockForPipeline(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.UpdateBlockForPipelineRequestProto req)
ClientNamenodeProtocolProtos.UpdatePipelineResponseProto	updatePipeline(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.UpdatePipelineRequestProto req)

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientNamenodeProtocolServerSideTranslatorPB

public ClientNamenodeProtocolServerSideTranslatorPB(ClientProtocol server)
                                             throws IOException

Constructor

Parameters:

server - - the NN server

Throws:

IOException

Method Detail

getBlockLocations

public ClientNamenodeProtocolProtos.GetBlockLocationsResponseProto getBlockLocations(com.google.protobuf.RpcController controller,
                                                                            ClientNamenodeProtocolProtos.GetBlockLocationsRequestProto req)
                                                                              throws com.google.protobuf.ServiceException

Specified by:

getBlockLocations in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

getServerDefaults

public ClientNamenodeProtocolProtos.GetServerDefaultsResponseProto getServerDefaults(com.google.protobuf.RpcController controller,
                                                                            ClientNamenodeProtocolProtos.GetServerDefaultsRequestProto req)
                                                                              throws com.google.protobuf.ServiceException

Specified by:

getServerDefaults in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

create

public ClientNamenodeProtocolProtos.CreateResponseProto create(com.google.protobuf.RpcController controller,
                                                      ClientNamenodeProtocolProtos.CreateRequestProto req)
                                                        throws com.google.protobuf.ServiceException

Specified by:

create in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

append

public ClientNamenodeProtocolProtos.AppendResponseProto append(com.google.protobuf.RpcController controller,
                                                      ClientNamenodeProtocolProtos.AppendRequestProto req)
                                                        throws com.google.protobuf.ServiceException

Specified by:

append in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

setReplication

public ClientNamenodeProtocolProtos.SetReplicationResponseProto setReplication(com.google.protobuf.RpcController controller,
                                                                      ClientNamenodeProtocolProtos.SetReplicationRequestProto req)
                                                                        throws com.google.protobuf.ServiceException

Specified by:

setReplication in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

setPermission

public ClientNamenodeProtocolProtos.SetPermissionResponseProto setPermission(com.google.protobuf.RpcController controller,
                                                                    ClientNamenodeProtocolProtos.SetPermissionRequestProto req)
                                                                      throws com.google.protobuf.ServiceException

Specified by:

setPermission in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

setOwner

public ClientNamenodeProtocolProtos.SetOwnerResponseProto setOwner(com.google.protobuf.RpcController controller,
                                                          ClientNamenodeProtocolProtos.SetOwnerRequestProto req)
                                                            throws com.google.protobuf.ServiceException

Specified by:

setOwner in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

abandonBlock

public ClientNamenodeProtocolProtos.AbandonBlockResponseProto abandonBlock(com.google.protobuf.RpcController controller,
                                                                  ClientNamenodeProtocolProtos.AbandonBlockRequestProto req)
                                                                    throws com.google.protobuf.ServiceException

Specified by:

abandonBlock in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

addBlock

public ClientNamenodeProtocolProtos.AddBlockResponseProto addBlock(com.google.protobuf.RpcController controller,
                                                          ClientNamenodeProtocolProtos.AddBlockRequestProto req)
                                                            throws com.google.protobuf.ServiceException

Specified by:

addBlock in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

getAdditionalDatanode

public ClientNamenodeProtocolProtos.GetAdditionalDatanodeResponseProto getAdditionalDatanode(com.google.protobuf.RpcController controller,
                                                                                    ClientNamenodeProtocolProtos.GetAdditionalDatanodeRequestProto req)
                                                                                      throws com.google.protobuf.ServiceException

Specified by:

getAdditionalDatanode in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

complete

public ClientNamenodeProtocolProtos.CompleteResponseProto complete(com.google.protobuf.RpcController controller,
                                                          ClientNamenodeProtocolProtos.CompleteRequestProto req)
                                                            throws com.google.protobuf.ServiceException

Specified by:

complete in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

reportBadBlocks

public ClientNamenodeProtocolProtos.ReportBadBlocksResponseProto reportBadBlocks(com.google.protobuf.RpcController controller,
                                                                        ClientNamenodeProtocolProtos.ReportBadBlocksRequestProto req)
                                                                          throws com.google.protobuf.ServiceException

Specified by:

reportBadBlocks in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

concat

public ClientNamenodeProtocolProtos.ConcatResponseProto concat(com.google.protobuf.RpcController controller,
                                                      ClientNamenodeProtocolProtos.ConcatRequestProto req)
                                                        throws com.google.protobuf.ServiceException

Specified by:

concat in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

rename

public ClientNamenodeProtocolProtos.RenameResponseProto rename(com.google.protobuf.RpcController controller,
                                                      ClientNamenodeProtocolProtos.RenameRequestProto req)
                                                        throws com.google.protobuf.ServiceException

Specified by:

rename in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

rename2

public ClientNamenodeProtocolProtos.Rename2ResponseProto rename2(com.google.protobuf.RpcController controller,
                                                        ClientNamenodeProtocolProtos.Rename2RequestProto req)
                                                          throws com.google.protobuf.ServiceException

Specified by:

rename2 in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

delete

public ClientNamenodeProtocolProtos.DeleteResponseProto delete(com.google.protobuf.RpcController controller,
                                                      ClientNamenodeProtocolProtos.DeleteRequestProto req)
                                                        throws com.google.protobuf.ServiceException

Specified by:

delete in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

mkdirs

public ClientNamenodeProtocolProtos.MkdirsResponseProto mkdirs(com.google.protobuf.RpcController controller,
                                                      ClientNamenodeProtocolProtos.MkdirsRequestProto req)
                                                        throws com.google.protobuf.ServiceException

Specified by:

mkdirs in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

getListing

public ClientNamenodeProtocolProtos.GetListingResponseProto getListing(com.google.protobuf.RpcController controller,
                                                              ClientNamenodeProtocolProtos.GetListingRequestProto req)
                                                                throws com.google.protobuf.ServiceException

Specified by:

getListing in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

renewLease

public ClientNamenodeProtocolProtos.RenewLeaseResponseProto renewLease(com.google.protobuf.RpcController controller,
                                                              ClientNamenodeProtocolProtos.RenewLeaseRequestProto req)
                                                                throws com.google.protobuf.ServiceException

Specified by:

renewLease in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

recoverLease

public ClientNamenodeProtocolProtos.RecoverLeaseResponseProto recoverLease(com.google.protobuf.RpcController controller,
                                                                  ClientNamenodeProtocolProtos.RecoverLeaseRequestProto req)
                                                                    throws com.google.protobuf.ServiceException

Specified by:

recoverLease in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

restoreFailedStorage

public ClientNamenodeProtocolProtos.RestoreFailedStorageResponseProto restoreFailedStorage(com.google.protobuf.RpcController controller,
                                                                                  ClientNamenodeProtocolProtos.RestoreFailedStorageRequestProto req)
                                                                                    throws com.google.protobuf.ServiceException

Specified by:

restoreFailedStorage in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

getFsStats

public ClientNamenodeProtocolProtos.GetFsStatsResponseProto getFsStats(com.google.protobuf.RpcController controller,
                                                              ClientNamenodeProtocolProtos.GetFsStatusRequestProto req)
                                                                throws com.google.protobuf.ServiceException

Specified by:

getFsStats in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

getDatanodeReport

public ClientNamenodeProtocolProtos.GetDatanodeReportResponseProto getDatanodeReport(com.google.protobuf.RpcController controller,
                                                                            ClientNamenodeProtocolProtos.GetDatanodeReportRequestProto req)
                                                                              throws com.google.protobuf.ServiceException

Specified by:

getDatanodeReport in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

getPreferredBlockSize

public ClientNamenodeProtocolProtos.GetPreferredBlockSizeResponseProto getPreferredBlockSize(com.google.protobuf.RpcController controller,
                                                                                    ClientNamenodeProtocolProtos.GetPreferredBlockSizeRequestProto req)
                                                                                      throws com.google.protobuf.ServiceException

Specified by:

getPreferredBlockSize in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

setSafeMode

public ClientNamenodeProtocolProtos.SetSafeModeResponseProto setSafeMode(com.google.protobuf.RpcController controller,
                                                                ClientNamenodeProtocolProtos.SetSafeModeRequestProto req)
                                                                  throws com.google.protobuf.ServiceException

Specified by:

setSafeMode in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

saveNamespace

public ClientNamenodeProtocolProtos.SaveNamespaceResponseProto saveNamespace(com.google.protobuf.RpcController controller,
                                                                    ClientNamenodeProtocolProtos.SaveNamespaceRequestProto req)
                                                                      throws com.google.protobuf.ServiceException

Specified by:

saveNamespace in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

rollEdits

public ClientNamenodeProtocolProtos.RollEditsResponseProto rollEdits(com.google.protobuf.RpcController controller,
                                                            ClientNamenodeProtocolProtos.RollEditsRequestProto request)
                                                              throws com.google.protobuf.ServiceException

Specified by:

rollEdits in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

refreshNodes

public ClientNamenodeProtocolProtos.RefreshNodesResponseProto refreshNodes(com.google.protobuf.RpcController controller,
                                                                  ClientNamenodeProtocolProtos.RefreshNodesRequestProto req)
                                                                    throws com.google.protobuf.ServiceException

Specified by:

refreshNodes in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

finalizeUpgrade

public ClientNamenodeProtocolProtos.FinalizeUpgradeResponseProto finalizeUpgrade(com.google.protobuf.RpcController controller,
                                                                        ClientNamenodeProtocolProtos.FinalizeUpgradeRequestProto req)
                                                                          throws com.google.protobuf.ServiceException

Specified by:

finalizeUpgrade in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

listCorruptFileBlocks

public ClientNamenodeProtocolProtos.ListCorruptFileBlocksResponseProto listCorruptFileBlocks(com.google.protobuf.RpcController controller,
                                                                                    ClientNamenodeProtocolProtos.ListCorruptFileBlocksRequestProto req)
                                                                                      throws com.google.protobuf.ServiceException

Specified by:

listCorruptFileBlocks in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

metaSave

public ClientNamenodeProtocolProtos.MetaSaveResponseProto metaSave(com.google.protobuf.RpcController controller,
                                                          ClientNamenodeProtocolProtos.MetaSaveRequestProto req)
                                                            throws com.google.protobuf.ServiceException

Specified by:

metaSave in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

getFileInfo

public ClientNamenodeProtocolProtos.GetFileInfoResponseProto getFileInfo(com.google.protobuf.RpcController controller,
                                                                ClientNamenodeProtocolProtos.GetFileInfoRequestProto req)
                                                                  throws com.google.protobuf.ServiceException

Specified by:

getFileInfo in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

getFileLinkInfo

public ClientNamenodeProtocolProtos.GetFileLinkInfoResponseProto getFileLinkInfo(com.google.protobuf.RpcController controller,
                                                                        ClientNamenodeProtocolProtos.GetFileLinkInfoRequestProto req)
                                                                          throws com.google.protobuf.ServiceException

Specified by:

getFileLinkInfo in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

getContentSummary

public ClientNamenodeProtocolProtos.GetContentSummaryResponseProto getContentSummary(com.google.protobuf.RpcController controller,
                                                                            ClientNamenodeProtocolProtos.GetContentSummaryRequestProto req)
                                                                              throws com.google.protobuf.ServiceException

Specified by:

getContentSummary in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

setQuota

public ClientNamenodeProtocolProtos.SetQuotaResponseProto setQuota(com.google.protobuf.RpcController controller,
                                                          ClientNamenodeProtocolProtos.SetQuotaRequestProto req)
                                                            throws com.google.protobuf.ServiceException

Specified by:

setQuota in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

fsync

public ClientNamenodeProtocolProtos.FsyncResponseProto fsync(com.google.protobuf.RpcController controller,
                                                    ClientNamenodeProtocolProtos.FsyncRequestProto req)
                                                      throws com.google.protobuf.ServiceException

Specified by:

fsync in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

setTimes

public ClientNamenodeProtocolProtos.SetTimesResponseProto setTimes(com.google.protobuf.RpcController controller,
                                                          ClientNamenodeProtocolProtos.SetTimesRequestProto req)
                                                            throws com.google.protobuf.ServiceException

Specified by:

setTimes in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

createSymlink

public ClientNamenodeProtocolProtos.CreateSymlinkResponseProto createSymlink(com.google.protobuf.RpcController controller,
                                                                    ClientNamenodeProtocolProtos.CreateSymlinkRequestProto req)
                                                                      throws com.google.protobuf.ServiceException

Specified by:

createSymlink in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

getLinkTarget

public ClientNamenodeProtocolProtos.GetLinkTargetResponseProto getLinkTarget(com.google.protobuf.RpcController controller,
                                                                    ClientNamenodeProtocolProtos.GetLinkTargetRequestProto req)
                                                                      throws com.google.protobuf.ServiceException

Specified by:

getLinkTarget in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

updateBlockForPipeline

public ClientNamenodeProtocolProtos.UpdateBlockForPipelineResponseProto updateBlockForPipeline(com.google.protobuf.RpcController controller,
                                                                                      ClientNamenodeProtocolProtos.UpdateBlockForPipelineRequestProto req)
                                                                                        throws com.google.protobuf.ServiceException

Specified by:

updateBlockForPipeline in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

updatePipeline

public ClientNamenodeProtocolProtos.UpdatePipelineResponseProto updatePipeline(com.google.protobuf.RpcController controller,
                                                                      ClientNamenodeProtocolProtos.UpdatePipelineRequestProto req)
                                                                        throws com.google.protobuf.ServiceException

Specified by:

updatePipeline in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

getDelegationToken

public SecurityProtos.GetDelegationTokenResponseProto getDelegationToken(com.google.protobuf.RpcController controller,
                                                                SecurityProtos.GetDelegationTokenRequestProto req)
                                                                  throws com.google.protobuf.ServiceException

Specified by:

getDelegationToken in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

renewDelegationToken

public SecurityProtos.RenewDelegationTokenResponseProto renewDelegationToken(com.google.protobuf.RpcController controller,
                                                                    SecurityProtos.RenewDelegationTokenRequestProto req)
                                                                      throws com.google.protobuf.ServiceException

Specified by:

renewDelegationToken in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

cancelDelegationToken

public SecurityProtos.CancelDelegationTokenResponseProto cancelDelegationToken(com.google.protobuf.RpcController controller,
                                                                      SecurityProtos.CancelDelegationTokenRequestProto req)
                                                                        throws com.google.protobuf.ServiceException

Specified by:

cancelDelegationToken in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

setBalancerBandwidth

public ClientNamenodeProtocolProtos.SetBalancerBandwidthResponseProto setBalancerBandwidth(com.google.protobuf.RpcController controller,
                                                                                  ClientNamenodeProtocolProtos.SetBalancerBandwidthRequestProto req)
                                                                                    throws com.google.protobuf.ServiceException

Specified by:

setBalancerBandwidth in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

getDataEncryptionKey

public ClientNamenodeProtocolProtos.GetDataEncryptionKeyResponseProto getDataEncryptionKey(com.google.protobuf.RpcController controller,
                                                                                  ClientNamenodeProtocolProtos.GetDataEncryptionKeyRequestProto request)
                                                                                    throws com.google.protobuf.ServiceException

Specified by:

getDataEncryptionKey in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

createSnapshot

public ClientNamenodeProtocolProtos.CreateSnapshotResponseProto createSnapshot(com.google.protobuf.RpcController controller,
                                                                      ClientNamenodeProtocolProtos.CreateSnapshotRequestProto req)
                                                                        throws com.google.protobuf.ServiceException

Specified by:

createSnapshot in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

deleteSnapshot

public ClientNamenodeProtocolProtos.DeleteSnapshotResponseProto deleteSnapshot(com.google.protobuf.RpcController controller,
                                                                      ClientNamenodeProtocolProtos.DeleteSnapshotRequestProto req)
                                                                        throws com.google.protobuf.ServiceException

Specified by:

deleteSnapshot in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

allowSnapshot

public ClientNamenodeProtocolProtos.AllowSnapshotResponseProto allowSnapshot(com.google.protobuf.RpcController controller,
                                                                    ClientNamenodeProtocolProtos.AllowSnapshotRequestProto req)
                                                                      throws com.google.protobuf.ServiceException

Specified by:

allowSnapshot in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

disallowSnapshot

public ClientNamenodeProtocolProtos.DisallowSnapshotResponseProto disallowSnapshot(com.google.protobuf.RpcController controller,
                                                                          ClientNamenodeProtocolProtos.DisallowSnapshotRequestProto req)
                                                                            throws com.google.protobuf.ServiceException

Specified by:

disallowSnapshot in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

renameSnapshot

public ClientNamenodeProtocolProtos.RenameSnapshotResponseProto renameSnapshot(com.google.protobuf.RpcController controller,
                                                                      ClientNamenodeProtocolProtos.RenameSnapshotRequestProto request)
                                                                        throws com.google.protobuf.ServiceException

Specified by:

renameSnapshot in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

getSnapshottableDirListing

public ClientNamenodeProtocolProtos.GetSnapshottableDirListingResponseProto getSnapshottableDirListing(com.google.protobuf.RpcController controller,
                                                                                              ClientNamenodeProtocolProtos.GetSnapshottableDirListingRequestProto request)
                                                                                                throws com.google.protobuf.ServiceException

Specified by:

getSnapshottableDirListing in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

getSnapshotDiffReport

public ClientNamenodeProtocolProtos.GetSnapshotDiffReportResponseProto getSnapshotDiffReport(com.google.protobuf.RpcController controller,
                                                                                    ClientNamenodeProtocolProtos.GetSnapshotDiffReportRequestProto request)
                                                                                      throws com.google.protobuf.ServiceException

Specified by:

getSnapshotDiffReport in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

isFileClosed

public ClientNamenodeProtocolProtos.IsFileClosedResponseProto isFileClosed(com.google.protobuf.RpcController controller,
                                                                  ClientNamenodeProtocolProtos.IsFileClosedRequestProto request)
                                                                    throws com.google.protobuf.ServiceException

Specified by:

isFileClosed in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException