@InterfaceAudience.Private @InterfaceStability.Stable public class ClientNamenodeProtocolServerSideTranslatorPB extends Object implements ClientNamenodeProtocolPB
ClientNamenodeProtocolPB
.
This class translates the PB data types
to the native data types used inside the NN as specified in the generic
ClientProtocol.Constructor and Description |
---|
ClientNamenodeProtocolServerSideTranslatorPB(ClientProtocol server)
Constructor
|
public ClientNamenodeProtocolServerSideTranslatorPB(ClientProtocol server) throws IOException
server
- - the NN serverIOException
public ClientNamenodeProtocolProtos.GetBlockLocationsResponseProto getBlockLocations(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.GetBlockLocationsRequestProto req) throws com.google.protobuf.ServiceException
getBlockLocations
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.GetServerDefaultsResponseProto getServerDefaults(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.GetServerDefaultsRequestProto req) throws com.google.protobuf.ServiceException
getServerDefaults
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.CreateResponseProto create(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.CreateRequestProto req) throws com.google.protobuf.ServiceException
create
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.AppendResponseProto append(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.AppendRequestProto req) throws com.google.protobuf.ServiceException
append
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.SetReplicationResponseProto setReplication(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.SetReplicationRequestProto req) throws com.google.protobuf.ServiceException
setReplication
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.SetPermissionResponseProto setPermission(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.SetPermissionRequestProto req) throws com.google.protobuf.ServiceException
setPermission
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.SetOwnerResponseProto setOwner(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.SetOwnerRequestProto req) throws com.google.protobuf.ServiceException
setOwner
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.AbandonBlockResponseProto abandonBlock(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.AbandonBlockRequestProto req) throws com.google.protobuf.ServiceException
abandonBlock
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.AddBlockResponseProto addBlock(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.AddBlockRequestProto req) throws com.google.protobuf.ServiceException
addBlock
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.GetAdditionalDatanodeResponseProto getAdditionalDatanode(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.GetAdditionalDatanodeRequestProto req) throws com.google.protobuf.ServiceException
getAdditionalDatanode
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.CompleteResponseProto complete(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.CompleteRequestProto req) throws com.google.protobuf.ServiceException
complete
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.ReportBadBlocksResponseProto reportBadBlocks(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.ReportBadBlocksRequestProto req) throws com.google.protobuf.ServiceException
reportBadBlocks
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.ConcatResponseProto concat(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.ConcatRequestProto req) throws com.google.protobuf.ServiceException
concat
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.RenameResponseProto rename(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.RenameRequestProto req) throws com.google.protobuf.ServiceException
rename
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.Rename2ResponseProto rename2(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.Rename2RequestProto req) throws com.google.protobuf.ServiceException
rename2
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.DeleteResponseProto delete(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.DeleteRequestProto req) throws com.google.protobuf.ServiceException
delete
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.MkdirsResponseProto mkdirs(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.MkdirsRequestProto req) throws com.google.protobuf.ServiceException
mkdirs
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.GetListingResponseProto getListing(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.GetListingRequestProto req) throws com.google.protobuf.ServiceException
getListing
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.RenewLeaseResponseProto renewLease(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.RenewLeaseRequestProto req) throws com.google.protobuf.ServiceException
renewLease
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.RecoverLeaseResponseProto recoverLease(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.RecoverLeaseRequestProto req) throws com.google.protobuf.ServiceException
recoverLease
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.RestoreFailedStorageResponseProto restoreFailedStorage(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.RestoreFailedStorageRequestProto req) throws com.google.protobuf.ServiceException
restoreFailedStorage
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.GetFsStatsResponseProto getFsStats(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.GetFsStatusRequestProto req) throws com.google.protobuf.ServiceException
getFsStats
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.GetDatanodeReportResponseProto getDatanodeReport(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.GetDatanodeReportRequestProto req) throws com.google.protobuf.ServiceException
getDatanodeReport
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.GetPreferredBlockSizeResponseProto getPreferredBlockSize(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.GetPreferredBlockSizeRequestProto req) throws com.google.protobuf.ServiceException
getPreferredBlockSize
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.SetSafeModeResponseProto setSafeMode(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.SetSafeModeRequestProto req) throws com.google.protobuf.ServiceException
setSafeMode
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.SaveNamespaceResponseProto saveNamespace(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.SaveNamespaceRequestProto req) throws com.google.protobuf.ServiceException
saveNamespace
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.RollEditsResponseProto rollEdits(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.RollEditsRequestProto request) throws com.google.protobuf.ServiceException
rollEdits
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.RefreshNodesResponseProto refreshNodes(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.RefreshNodesRequestProto req) throws com.google.protobuf.ServiceException
refreshNodes
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.FinalizeUpgradeResponseProto finalizeUpgrade(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.FinalizeUpgradeRequestProto req) throws com.google.protobuf.ServiceException
finalizeUpgrade
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.ListCorruptFileBlocksResponseProto listCorruptFileBlocks(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.ListCorruptFileBlocksRequestProto req) throws com.google.protobuf.ServiceException
listCorruptFileBlocks
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.MetaSaveResponseProto metaSave(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.MetaSaveRequestProto req) throws com.google.protobuf.ServiceException
metaSave
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.GetFileInfoResponseProto getFileInfo(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.GetFileInfoRequestProto req) throws com.google.protobuf.ServiceException
getFileInfo
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.GetFileLinkInfoResponseProto getFileLinkInfo(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.GetFileLinkInfoRequestProto req) throws com.google.protobuf.ServiceException
getFileLinkInfo
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.GetContentSummaryResponseProto getContentSummary(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.GetContentSummaryRequestProto req) throws com.google.protobuf.ServiceException
getContentSummary
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.SetQuotaResponseProto setQuota(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.SetQuotaRequestProto req) throws com.google.protobuf.ServiceException
setQuota
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.FsyncResponseProto fsync(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.FsyncRequestProto req) throws com.google.protobuf.ServiceException
fsync
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.SetTimesResponseProto setTimes(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.SetTimesRequestProto req) throws com.google.protobuf.ServiceException
setTimes
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.CreateSymlinkResponseProto createSymlink(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.CreateSymlinkRequestProto req) throws com.google.protobuf.ServiceException
createSymlink
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.GetLinkTargetResponseProto getLinkTarget(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.GetLinkTargetRequestProto req) throws com.google.protobuf.ServiceException
getLinkTarget
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.UpdateBlockForPipelineResponseProto updateBlockForPipeline(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.UpdateBlockForPipelineRequestProto req) throws com.google.protobuf.ServiceException
updateBlockForPipeline
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.UpdatePipelineResponseProto updatePipeline(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.UpdatePipelineRequestProto req) throws com.google.protobuf.ServiceException
updatePipeline
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public SecurityProtos.GetDelegationTokenResponseProto getDelegationToken(com.google.protobuf.RpcController controller, SecurityProtos.GetDelegationTokenRequestProto req) throws com.google.protobuf.ServiceException
getDelegationToken
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public SecurityProtos.RenewDelegationTokenResponseProto renewDelegationToken(com.google.protobuf.RpcController controller, SecurityProtos.RenewDelegationTokenRequestProto req) throws com.google.protobuf.ServiceException
renewDelegationToken
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public SecurityProtos.CancelDelegationTokenResponseProto cancelDelegationToken(com.google.protobuf.RpcController controller, SecurityProtos.CancelDelegationTokenRequestProto req) throws com.google.protobuf.ServiceException
cancelDelegationToken
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.SetBalancerBandwidthResponseProto setBalancerBandwidth(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.SetBalancerBandwidthRequestProto req) throws com.google.protobuf.ServiceException
setBalancerBandwidth
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.GetDataEncryptionKeyResponseProto getDataEncryptionKey(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.GetDataEncryptionKeyRequestProto request) throws com.google.protobuf.ServiceException
getDataEncryptionKey
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.CreateSnapshotResponseProto createSnapshot(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.CreateSnapshotRequestProto req) throws com.google.protobuf.ServiceException
createSnapshot
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.DeleteSnapshotResponseProto deleteSnapshot(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.DeleteSnapshotRequestProto req) throws com.google.protobuf.ServiceException
deleteSnapshot
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.AllowSnapshotResponseProto allowSnapshot(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.AllowSnapshotRequestProto req) throws com.google.protobuf.ServiceException
allowSnapshot
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.DisallowSnapshotResponseProto disallowSnapshot(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.DisallowSnapshotRequestProto req) throws com.google.protobuf.ServiceException
disallowSnapshot
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.RenameSnapshotResponseProto renameSnapshot(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.RenameSnapshotRequestProto request) throws com.google.protobuf.ServiceException
renameSnapshot
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.GetSnapshottableDirListingResponseProto getSnapshottableDirListing(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.GetSnapshottableDirListingRequestProto request) throws com.google.protobuf.ServiceException
getSnapshottableDirListing
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.GetSnapshotDiffReportResponseProto getSnapshotDiffReport(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.GetSnapshotDiffReportRequestProto request) throws com.google.protobuf.ServiceException
getSnapshotDiffReport
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
public ClientNamenodeProtocolProtos.IsFileClosedResponseProto isFileClosed(com.google.protobuf.RpcController controller, ClientNamenodeProtocolProtos.IsFileClosedRequestProto request) throws com.google.protobuf.ServiceException
isFileClosed
in interface ClientNamenodeProtocolProtos.ClientNamenodeProtocol.BlockingInterface
com.google.protobuf.ServiceException
Copyright © 2013 Apache Software Foundation. All rights reserved.