Modifier and Type | Method and Description |
---|---|
Token<?>[] |
FileSystem.addDelegationTokens(String renewer,
Credentials credentials)
Obtain all delegation tokens used by this FileSystem that are not
already present in the given Credentials.
|
Token<?> |
FileSystem.getDelegationToken(String renewer)
Get a new delegation token for this file system.
|
Token<?> |
DelegationTokenRenewer.Renewable.getRenewToken() |
Modifier and Type | Method and Description |
---|---|
List<Token<?>> |
FileContext.getDelegationTokens(Path p,
String renewer)
Get delegation tokens for the file systems accessed for a given
path.
|
List<Token<?>> |
Hdfs.getDelegationTokens(String renewer) |
List<Token<?>> |
AbstractFileSystem.getDelegationTokens(String renewer)
Get one or more delegation tokens associated with the filesystem.
|
List<Token<?>> |
FilterFs.getDelegationTokens(String renewer) |
List<Token<?>> |
DelegateToFileSystem.getDelegationTokens(String renewer) |
Modifier and Type | Method and Description |
---|---|
void |
Hdfs.cancelDelegationToken(Token<? extends AbstractDelegationTokenIdentifier> token)
Deprecated.
Use Token.cancel instead.
|
long |
Hdfs.renewDelegationToken(Token<? extends AbstractDelegationTokenIdentifier> token)
Deprecated.
Use Token.renew instead.
|
<T extends TokenIdentifier> |
DelegationTokenRenewer.Renewable.setDelegationToken(Token<T> token)
Set delegation token.
|
Modifier and Type | Method and Description |
---|---|
Token<?> |
HttpFSFileSystem.getDelegationToken(String renewer) |
static Token<?> |
HttpFSKerberosAuthenticator.getDelegationToken(URI fsURI,
InetSocketAddress httpFSAddr,
AuthenticatedURL.Token token,
String renewer) |
Token<?> |
HttpFSFileSystem.getRenewToken() |
Modifier and Type | Method and Description |
---|---|
void |
HttpFSFileSystem.cancelDelegationToken(Token<?> token) |
static void |
HttpFSKerberosAuthenticator.cancelDelegationToken(URI fsURI,
AuthenticatedURL.Token token,
Token<?> dToken) |
static void |
HttpFSKerberosAuthenticator.injectDelegationToken(Map<String,String> params,
Token<?> dtToken) |
long |
HttpFSFileSystem.renewDelegationToken(Token<?> token) |
static long |
HttpFSKerberosAuthenticator.renewDelegationToken(URI fsURI,
AuthenticatedURL.Token token,
Token<?> dToken) |
<T extends TokenIdentifier> |
HttpFSFileSystem.setDelegationToken(Token<T> token) |
Modifier and Type | Method and Description |
---|---|
List<Token<?>> |
ViewFs.getDelegationTokens(String renewer) |
Modifier and Type | Method and Description |
---|---|
Token<?> |
HftpFileSystem.getDelegationToken(String renewer) |
Token<DelegationTokenIdentifier> |
DistributedFileSystem.getDelegationToken(String renewer) |
Token<DelegationTokenIdentifier> |
DistributedFileSystem.getDelegationToken(Text renewer)
Deprecated.
|
Token<DelegationTokenIdentifier> |
DFSClient.getDelegationToken(Text renewer) |
Token<?> |
HftpFileSystem.getRenewToken() |
protected Token<DelegationTokenIdentifier> |
HftpFileSystem.selectDelegationToken(UserGroupInformation ugi) |
Modifier and Type | Method and Description |
---|---|
void |
HftpFileSystem.TokenManager.cancel(Token<?> token,
Configuration conf) |
void |
DFSClient.Renewer.cancel(Token<?> token,
Configuration conf) |
void |
DistributedFileSystem.cancelDelegationToken(Token<DelegationTokenIdentifier> token)
Deprecated.
Use Token.cancel instead.
|
void |
DFSClient.cancelDelegationToken(Token<DelegationTokenIdentifier> token)
Deprecated.
Use Token.cancel instead.
|
protected BlockReader |
DFSInputStream.getBlockReader(InetSocketAddress dnAddr,
DatanodeInfo chosenNode,
String file,
ExtendedBlock block,
Token<BlockTokenIdentifier> blockToken,
long startOffset,
long len,
int bufferSize,
boolean verifyChecksum,
String clientName)
Retrieve a BlockReader suitable for reading.
|
static URI |
HAUtil.getServiceUriFromToken(Token<DelegationTokenIdentifier> token)
Parse the HDFS URI out of the provided token.
|
boolean |
HftpFileSystem.TokenManager.isManaged(Token<?> token) |
boolean |
DFSClient.Renewer.isManaged(Token<?> token) |
static boolean |
HAUtil.isTokenForLogicalUri(Token<DelegationTokenIdentifier> token) |
static BlockReader |
BlockReaderFactory.newBlockReader(DFSClient.Conf conf,
String file,
ExtendedBlock block,
Token<BlockTokenIdentifier> blockToken,
long startOffset,
long len,
boolean verifyChecksum,
String clientName,
Peer peer,
DatanodeID datanodeID,
org.apache.hadoop.hdfs.DomainSocketFactory domSockFactory,
org.apache.hadoop.hdfs.PeerCache peerCache,
org.apache.hadoop.hdfs.FileInputStreamCache fisCache,
boolean allowShortCircuitLocalReads,
CachingStrategy cachingStrategy)
Create a new BlockReader specifically to satisfy a read.
|
static BlockReader |
RemoteBlockReader2.newBlockReader(String file,
ExtendedBlock block,
Token<BlockTokenIdentifier> blockToken,
long startOffset,
long len,
boolean verifyChecksum,
String clientName,
Peer peer,
DatanodeID datanodeID,
org.apache.hadoop.hdfs.PeerCache peerCache,
CachingStrategy cachingStrategy)
Create a new BlockReader specifically to satisfy a read.
|
static RemoteBlockReader |
RemoteBlockReader.newBlockReader(String file,
ExtendedBlock block,
Token<BlockTokenIdentifier> blockToken,
long startOffset,
long len,
int bufferSize,
boolean verifyChecksum,
String clientName,
Peer peer,
DatanodeID datanodeID,
org.apache.hadoop.hdfs.PeerCache peerCache,
CachingStrategy cachingStrategy)
Deprecated.
Create a new BlockReader specifically to satisfy a read.
|
long |
HftpFileSystem.TokenManager.renew(Token<?> token,
Configuration conf) |
long |
DFSClient.Renewer.renew(Token<?> token,
Configuration conf) |
long |
DistributedFileSystem.renewDelegationToken(Token<DelegationTokenIdentifier> token)
Deprecated.
Use Token.renew instead.
|
long |
DFSClient.renewDelegationToken(Token<DelegationTokenIdentifier> token)
Deprecated.
Use Token.renew instead.
|
<T extends TokenIdentifier> |
HftpFileSystem.setDelegationToken(Token<T> token) |
Modifier and Type | Method and Description |
---|---|
Token<BlockTokenIdentifier> |
LocatedBlock.getBlockToken() |
Token<DelegationTokenIdentifier> |
ClientProtocol.getDelegationToken(Text renewer)
Get a valid Delegation Token.
|
Modifier and Type | Method and Description |
---|---|
void |
ClientProtocol.cancelDelegationToken(Token<DelegationTokenIdentifier> token)
Cancel an existing delegation token.
|
BlockLocalPathInfo |
ClientDatanodeProtocol.getBlockLocalPathInfo(ExtendedBlock block,
Token<BlockTokenIdentifier> token)
Retrieves the path names of the block file and metadata file stored on the
local file system.
|
long |
ClientProtocol.renewDelegationToken(Token<DelegationTokenIdentifier> token)
Renew an existing delegation token.
|
void |
LocatedBlock.setBlockToken(Token<BlockTokenIdentifier> token) |
Modifier and Type | Method and Description |
---|---|
HdfsBlocksMetadata |
ClientDatanodeProtocol.getHdfsBlocksMetadata(List<ExtendedBlock> blocks,
List<Token<BlockTokenIdentifier>> tokens)
Retrieves volume location information about a list of blocks on a datanode.
|
Modifier and Type | Method and Description |
---|---|
void |
Sender.blockChecksum(ExtendedBlock blk,
Token<BlockTokenIdentifier> blockToken) |
void |
DataTransferProtocol.blockChecksum(ExtendedBlock blk,
Token<BlockTokenIdentifier> blockToken)
Get block checksum (MD5 of CRC32).
|
void |
Sender.copyBlock(ExtendedBlock blk,
Token<BlockTokenIdentifier> blockToken) |
void |
DataTransferProtocol.copyBlock(ExtendedBlock blk,
Token<BlockTokenIdentifier> blockToken)
Copy a block.
|
void |
Sender.readBlock(ExtendedBlock blk,
Token<BlockTokenIdentifier> blockToken,
String clientName,
long blockOffset,
long length,
boolean sendChecksum,
CachingStrategy cachingStrategy) |
void |
DataTransferProtocol.readBlock(ExtendedBlock blk,
Token<BlockTokenIdentifier> blockToken,
String clientName,
long blockOffset,
long length,
boolean sendChecksum,
CachingStrategy cachingStrategy)
Read a block.
|
void |
Sender.replaceBlock(ExtendedBlock blk,
Token<BlockTokenIdentifier> blockToken,
String delHint,
DatanodeInfo source) |
void |
DataTransferProtocol.replaceBlock(ExtendedBlock blk,
Token<BlockTokenIdentifier> blockToken,
String delHint,
DatanodeInfo source)
Receive a block from a source datanode
and then notifies the namenode
to remove the copy from the original datanode.
|
void |
Sender.requestShortCircuitFds(ExtendedBlock blk,
Token<BlockTokenIdentifier> blockToken,
int maxVersion) |
void |
DataTransferProtocol.requestShortCircuitFds(ExtendedBlock blk,
Token<BlockTokenIdentifier> blockToken,
int maxVersion)
Request short circuit access file descriptors from a DataNode.
|
void |
Sender.transferBlock(ExtendedBlock blk,
Token<BlockTokenIdentifier> blockToken,
String clientName,
DatanodeInfo[] targets) |
void |
DataTransferProtocol.transferBlock(ExtendedBlock blk,
Token<BlockTokenIdentifier> blockToken,
String clientName,
DatanodeInfo[] targets)
Transfer a block to another datanode.
|
void |
Sender.writeBlock(ExtendedBlock blk,
Token<BlockTokenIdentifier> blockToken,
String clientName,
DatanodeInfo[] targets,
DatanodeInfo source,
BlockConstructionStage stage,
int pipelineSize,
long minBytesRcvd,
long maxBytesRcvd,
long latestGenerationStamp,
DataChecksum requestedChecksum,
CachingStrategy cachingStrategy) |
void |
DataTransferProtocol.writeBlock(ExtendedBlock blk,
Token<BlockTokenIdentifier> blockToken,
String clientName,
DatanodeInfo[] targets,
DatanodeInfo source,
BlockConstructionStage stage,
int pipelineSize,
long minBytesRcvd,
long maxBytesRcvd,
long latestGenerationStamp,
DataChecksum requestedChecksum,
CachingStrategy cachingStrategy)
Write a block to a datanode pipeline.
|
Modifier and Type | Method and Description |
---|---|
static Token<BlockTokenIdentifier> |
PBHelper.convert(SecurityProtos.TokenProto blockToken) |
static Token<DelegationTokenIdentifier> |
PBHelper.convertDelegationToken(SecurityProtos.TokenProto blockToken) |
Token<DelegationTokenIdentifier> |
ClientNamenodeProtocolTranslatorPB.getDelegationToken(Text renewer) |
Modifier and Type | Method and Description |
---|---|
void |
ClientNamenodeProtocolTranslatorPB.cancelDelegationToken(Token<DelegationTokenIdentifier> token) |
static SecurityProtos.TokenProto |
PBHelper.convert(Token<?> tok) |
BlockLocalPathInfo |
ClientDatanodeProtocolTranslatorPB.getBlockLocalPathInfo(ExtendedBlock block,
Token<BlockTokenIdentifier> token) |
long |
ClientNamenodeProtocolTranslatorPB.renewDelegationToken(Token<DelegationTokenIdentifier> token) |
Modifier and Type | Method and Description |
---|---|
HdfsBlocksMetadata |
ClientDatanodeProtocolTranslatorPB.getHdfsBlocksMetadata(List<ExtendedBlock> blocks,
List<Token<BlockTokenIdentifier>> tokens) |
Modifier and Type | Field and Description |
---|---|
static Token<BlockTokenIdentifier> |
BlockTokenSecretManager.DUMMY_TOKEN |
Modifier and Type | Method and Description |
---|---|
Token<BlockTokenIdentifier> |
BlockTokenSecretManager.generateToken(ExtendedBlock block,
EnumSet<BlockTokenSecretManager.AccessMode> modes)
Generate an block token for current user
|
Token<BlockTokenIdentifier> |
BlockPoolTokenSecretManager.generateToken(ExtendedBlock b,
EnumSet<BlockTokenSecretManager.AccessMode> of)
|
Token<BlockTokenIdentifier> |
BlockTokenSecretManager.generateToken(String userId,
ExtendedBlock block,
EnumSet<BlockTokenSecretManager.AccessMode> modes)
Generate a block token for a specified user
|
Token<BlockTokenIdentifier> |
BlockTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Modifier and Type | Method and Description |
---|---|
void |
BlockTokenSecretManager.checkAccess(Token<BlockTokenIdentifier> token,
String userId,
ExtendedBlock block,
BlockTokenSecretManager.AccessMode mode)
Check if access should be allowed.
|
void |
BlockPoolTokenSecretManager.checkAccess(Token<BlockTokenIdentifier> token,
String userId,
ExtendedBlock block,
BlockTokenSecretManager.AccessMode mode)
|
Modifier and Type | Method and Description |
---|---|
Token<BlockTokenIdentifier> |
BlockTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Modifier and Type | Method and Description |
---|---|
Token<DelegationTokenIdentifier> |
DelegationTokenSelector.selectToken(URI nnUri,
Collection<Token<?>> tokens,
Configuration conf)
Select the delegation token for hdfs.
|
Modifier and Type | Method and Description |
---|---|
static String |
DelegationTokenIdentifier.stringifyToken(Token<?> token) |
Modifier and Type | Method and Description |
---|---|
Token<DelegationTokenIdentifier> |
DelegationTokenSelector.selectToken(URI nnUri,
Collection<Token<?>> tokens,
Configuration conf)
Select the delegation token for hdfs.
|
Modifier and Type | Method and Description |
---|---|
static void |
JspHelper.streamBlockInAscii(InetSocketAddress addr,
String poolId,
long blockId,
Token<BlockTokenIdentifier> blockToken,
long genStamp,
long blockSize,
long offsetIntoBlock,
long chunkSizeToView,
javax.servlet.jsp.JspWriter out,
Configuration conf,
DFSClient.Conf dfsConf,
DataEncryptionKey encryptionKey) |
Modifier and Type | Method and Description |
---|---|
BlockLocalPathInfo |
DataNode.getBlockLocalPathInfo(ExtendedBlock block,
Token<BlockTokenIdentifier> token) |
Modifier and Type | Method and Description |
---|---|
HdfsBlocksMetadata |
DataNode.getHdfsBlocksMetadata(List<ExtendedBlock> blocks,
List<Token<BlockTokenIdentifier>> tokens) |
Modifier and Type | Method and Description |
---|---|
static void |
DelegationTokenFetcher.cancelDelegationToken(String nnAddr,
Token<DelegationTokenIdentifier> tok)
Cancel a Delegation Token.
|
static long |
DelegationTokenFetcher.renewDelegationToken(String nnAddr,
Token<DelegationTokenIdentifier> tok)
Renew a Delegation Token.
|
Modifier and Type | Method and Description |
---|---|
protected Token<?> |
WebHdfsFileSystem.getDelegationToken() |
Token<DelegationTokenIdentifier> |
WebHdfsFileSystem.getDelegationToken(String renewer) |
Token<?> |
WebHdfsFileSystem.getRenewToken() |
protected Token<DelegationTokenIdentifier> |
WebHdfsFileSystem.selectDelegationToken(UserGroupInformation ugi) |
static Token<DelegationTokenIdentifier> |
JsonUtil.toDelegationToken(Map<?,?> json)
Convert a Json map to a Token of DelegationTokenIdentifier.
|
static Token<? extends TokenIdentifier> |
JsonUtil.toToken(Map<?,?> m)
Convert a Json map to a Token.
|
Modifier and Type | Method and Description |
---|---|
static List<Token<?>> |
JsonUtil.toTokenList(Map<?,?> json)
Convert a JSON map to a List
|
Modifier and Type | Method and Description |
---|---|
void |
WebHdfsFileSystem.DtRenewer.cancel(Token<?> token,
Configuration conf) |
boolean |
WebHdfsFileSystem.DtRenewer.isManaged(Token<?> token) |
long |
WebHdfsFileSystem.DtRenewer.renew(Token<?> token,
Configuration conf) |
<T extends TokenIdentifier> |
WebHdfsFileSystem.setDelegationToken(Token<T> token) |
static String |
JsonUtil.toJsonString(Token<? extends TokenIdentifier> token)
Convert a token object to a Json string.
|
static String |
JsonUtil.toJsonString(Token<? extends TokenIdentifier>[] tokens)
Convert a token object to a JSON string.
|
Modifier and Type | Method and Description |
---|---|
Token<DelegationTokenIdentifier> |
DelegationTokenManager.createToken(UserGroupInformation ugi,
String renewer)
Creates a delegation token.
|
Modifier and Type | Method and Description |
---|---|
void |
DelegationTokenManager.cancelToken(Token<DelegationTokenIdentifier> token,
String canceler)
Cancels a delegation token.
|
long |
DelegationTokenManager.renewToken(Token<DelegationTokenIdentifier> token,
String renewer)
Renews a delegation token.
|
UserGroupInformation |
DelegationTokenManager.verifyToken(Token<DelegationTokenIdentifier> token)
Verifies a delegation token.
|
Modifier and Type | Method and Description |
---|---|
Token<DelegationTokenIdentifier> |
DelegationTokenManagerService.createToken(UserGroupInformation ugi,
String renewer)
Creates a delegation token.
|
Modifier and Type | Method and Description |
---|---|
void |
DelegationTokenManagerService.cancelToken(Token<DelegationTokenIdentifier> token,
String canceler)
Cancels a delegation token.
|
long |
DelegationTokenManagerService.renewToken(Token<DelegationTokenIdentifier> token,
String renewer)
Renews a delegation token.
|
UserGroupInformation |
DelegationTokenManagerService.verifyToken(Token<DelegationTokenIdentifier> token)
Verifies a delegation token.
|
Modifier and Type | Method and Description |
---|---|
Token<AMRMTokenIdentifier> |
ResourceMgrDelegate.getAMRMToken(ApplicationId appId) |
Token<DelegationTokenIdentifier> |
YARNRunner.getDelegationToken(Text renewer) |
Token |
ResourceMgrDelegate.getDelegationToken(Text renewer) |
Token<DelegationTokenIdentifier> |
LocalJobRunner.getDelegationToken(Text renewer) |
Token<DelegationTokenIdentifier> |
JobClient.getDelegationToken(Text renewer)
Get a delegation token for the user from the JobTracker.
|
Modifier and Type | Method and Description |
---|---|
void |
YARNRunner.cancelDelegationToken(Token<DelegationTokenIdentifier> arg0) |
void |
LocalJobRunner.cancelDelegationToken(Token<DelegationTokenIdentifier> token) |
void |
JobClient.cancelDelegationToken(Token<DelegationTokenIdentifier> token)
Deprecated.
Use
cancel(org.apache.hadoop.conf.Configuration) instead |
long |
YARNRunner.renewDelegationToken(Token<DelegationTokenIdentifier> arg0) |
long |
LocalJobRunner.renewDelegationToken(Token<DelegationTokenIdentifier> token) |
long |
JobClient.renewDelegationToken(Token<DelegationTokenIdentifier> token)
Deprecated.
Use
renew(org.apache.hadoop.conf.Configuration) instead |
static ByteBuffer |
ShuffleHandler.serializeServiceData(Token<JobTokenIdentifier> jobToken)
A helper function to serialize the JobTokenIdentifier to be sent to the
ShuffleHandler as ServiceData.
|
Constructor and Description |
---|
MapTaskAttemptImpl(TaskId taskId,
int attempt,
EventHandler eventHandler,
Path jobFile,
int partition,
JobSplit.TaskSplitMetaInfo splitInfo,
JobConf conf,
TaskAttemptListener taskAttemptListener,
Token<JobTokenIdentifier> jobToken,
Credentials credentials,
Clock clock,
AppContext appContext) |
ReduceTaskAttemptImpl(TaskId id,
int attempt,
EventHandler eventHandler,
Path jobFile,
int partition,
int numMapTasks,
JobConf conf,
TaskAttemptListener taskAttemptListener,
Token<JobTokenIdentifier> jobToken,
Credentials credentials,
Clock clock,
AppContext appContext) |
Modifier and Type | Method and Description |
---|---|
Token<DelegationTokenIdentifier> |
Cluster.getDelegationToken(Text renewer)
Get a delegation token for the user from the JobTracker.
|
Modifier and Type | Method and Description |
---|---|
void |
Cluster.cancelDelegationToken(Token<DelegationTokenIdentifier> token)
Deprecated.
Use
cancel(org.apache.hadoop.conf.Configuration) instead |
long |
Cluster.renewDelegationToken(Token<DelegationTokenIdentifier> token)
Deprecated.
Use
renew(org.apache.hadoop.conf.Configuration) instead |
Modifier and Type | Method and Description |
---|---|
Token<DelegationTokenIdentifier> |
ClientProtocol.getDelegationToken(Text renewer)
Get a new delegation token.
|
Modifier and Type | Method and Description |
---|---|
void |
ClientProtocol.cancelDelegationToken(Token<DelegationTokenIdentifier> token)
Cancel a delegation token.
|
long |
ClientProtocol.renewDelegationToken(Token<DelegationTokenIdentifier> token)
Renew an existing delegation token
|
Modifier and Type | Method and Description |
---|---|
static Token<?> |
TokenCache.getDelegationToken(Credentials credentials,
String namenode)
Deprecated.
Use
Credentials.getToken(org.apache.hadoop.io.Text)
instead, this method is included for compatibility against Hadoop-1 |
static Token<JobTokenIdentifier> |
TokenCache.getJobToken(Credentials credentials) |
Modifier and Type | Method and Description |
---|---|
static void |
TokenCache.setJobToken(Token<? extends TokenIdentifier> t,
Credentials credentials)
store job token
|
Modifier and Type | Method and Description |
---|---|
Token<JobTokenIdentifier> |
JobTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Modifier and Type | Method and Description |
---|---|
void |
JobTokenSecretManager.addTokenForJob(String jobId,
Token<JobTokenIdentifier> token)
Add the job token of a job to cache
|
Modifier and Type | Method and Description |
---|---|
Token<JobTokenIdentifier> |
JobTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Modifier and Type | Field and Description |
---|---|
protected Token<JobTokenIdentifier> |
TaskImpl.jobToken |
Constructor and Description |
---|
MapTaskImpl(JobId jobId,
int partition,
EventHandler eventHandler,
Path remoteJobConfFile,
JobConf conf,
JobSplit.TaskSplitMetaInfo taskSplitMetaInfo,
TaskAttemptListener taskAttemptListener,
Token<JobTokenIdentifier> jobToken,
Credentials credentials,
Clock clock,
int appAttemptId,
MRAppMetrics metrics,
AppContext appContext) |
ReduceTaskImpl(JobId jobId,
int partition,
EventHandler eventHandler,
Path jobFile,
JobConf conf,
int numMapTasks,
TaskAttemptListener taskAttemptListener,
Token<JobTokenIdentifier> jobToken,
Credentials credentials,
Clock clock,
int appAttemptId,
MRAppMetrics metrics,
AppContext appContext) |
TaskAttemptImpl(TaskId taskId,
int i,
EventHandler eventHandler,
TaskAttemptListener taskAttemptListener,
Path jobFile,
int partition,
JobConf conf,
String[] dataLocalHosts,
Token<JobTokenIdentifier> jobToken,
Credentials credentials,
Clock clock,
AppContext appContext) |
TaskImpl(JobId jobId,
TaskType taskType,
int partition,
EventHandler eventHandler,
Path remoteJobConfFile,
JobConf conf,
TaskAttemptListener taskAttemptListener,
Token<JobTokenIdentifier> jobToken,
Credentials credentials,
Clock clock,
int appAttemptId,
MRAppMetrics metrics,
AppContext appContext) |
Modifier and Type | Method and Description |
---|---|
void |
MRDelegationTokenRenewer.cancel(Token<?> token,
Configuration conf) |
boolean |
MRDelegationTokenRenewer.isManaged(Token<?> token) |
long |
MRDelegationTokenRenewer.renew(Token<?> token,
Configuration conf) |
Modifier and Type | Method and Description |
---|---|
Token<MRDelegationTokenIdentifier> |
ClientHSTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Modifier and Type | Method and Description |
---|---|
Token<MRDelegationTokenIdentifier> |
ClientHSTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Modifier and Type | Method and Description |
---|---|
Token<? extends TokenIdentifier> |
Credentials.getToken(Text alias)
Returns the Token object for the alias
|
Modifier and Type | Method and Description |
---|---|
Collection<Token<? extends TokenIdentifier>> |
Credentials.getAllTokens()
Return all the tokens in the in-memory map
|
Collection<Token<? extends TokenIdentifier>> |
UserGroupInformation.getTokens()
Obtain the collection of tokens associated with this user.
|
Modifier and Type | Method and Description |
---|---|
boolean |
UserGroupInformation.addToken(Text alias,
Token<? extends TokenIdentifier> token)
Add a named token to this UGI
|
void |
Credentials.addToken(Text alias,
Token<? extends TokenIdentifier> t)
Add a token in the storage (in memory)
|
boolean |
UserGroupInformation.addToken(Token<? extends TokenIdentifier> token)
Add a token to this UGI
|
static InetSocketAddress |
SecurityUtil.getTokenServiceAddr(Token<?> token)
Decode the given token's service field into an InetAddress
|
static void |
SecurityUtil.setTokenService(Token<?> token,
InetSocketAddress addr)
Set the given token's service to the format expected by the RPC client
|
Modifier and Type | Class and Description |
---|---|
static class |
Token.PrivateToken<T extends TokenIdentifier>
Indicates whether the token is a clone.
|
Modifier and Type | Method and Description |
---|---|
Token<T> |
TokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Modifier and Type | Method and Description |
---|---|
abstract void |
TokenRenewer.cancel(Token<?> token,
Configuration conf)
Cancel the given token
|
void |
Token.TrivialRenewer.cancel(Token<?> token,
Configuration conf) |
abstract boolean |
TokenRenewer.isManaged(Token<?> token)
Is the given token managed? Only managed tokens may be renewed or
cancelled.
|
boolean |
Token.TrivialRenewer.isManaged(Token<?> token) |
abstract long |
TokenRenewer.renew(Token<?> token,
Configuration conf)
Renew the given token.
|
long |
Token.TrivialRenewer.renew(Token<?> token,
Configuration conf) |
Modifier and Type | Method and Description |
---|---|
Token<T> |
TokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Constructor and Description |
---|
Token.PrivateToken(Token<T> token) |
Token(Token<T> other)
Clone a token.
|
Modifier and Type | Method and Description |
---|---|
Token<TokenIdent> |
AbstractDelegationTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Modifier and Type | Method and Description |
---|---|
TokenIdent |
AbstractDelegationTokenSecretManager.cancelToken(Token<TokenIdent> token,
String canceller)
Cancel a token by removing it from cache.
|
long |
AbstractDelegationTokenSecretManager.renewToken(Token<TokenIdent> token,
String renewer)
Renew a delegation token.
|
Modifier and Type | Method and Description |
---|---|
Token<TokenIdent> |
AbstractDelegationTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Modifier and Type | Method and Description |
---|---|
abstract Token<AMRMTokenIdentifier> |
YarnClient.getAMRMToken(ApplicationId appId)
Get the AMRM token of the application.
|
Modifier and Type | Method and Description |
---|---|
Token<AMRMTokenIdentifier> |
YarnClientImpl.getAMRMToken(ApplicationId appId) |
Modifier and Type | Method and Description |
---|---|
Token<ContainerTokenIdentifier> |
ContainerTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Token<NMTokenIdentifier> |
NMTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Token<AMRMTokenIdentifier> |
AMRMTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Modifier and Type | Method and Description |
---|---|
Token<ContainerTokenIdentifier> |
ContainerTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Token<NMTokenIdentifier> |
NMTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Token<AMRMTokenIdentifier> |
AMRMTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Modifier and Type | Method and Description |
---|---|
Token<RMDelegationTokenIdentifier> |
RMDelegationTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Token<ClientToAMTokenIdentifier> |
ClientToAMTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Modifier and Type | Method and Description |
---|---|
void |
RMDelegationTokenIdentifier.Renewer.cancel(Token<?> token,
Configuration conf) |
boolean |
RMDelegationTokenIdentifier.Renewer.isManaged(Token<?> token) |
long |
RMDelegationTokenIdentifier.Renewer.renew(Token<?> token,
Configuration conf) |
Modifier and Type | Method and Description |
---|---|
Token<RMDelegationTokenIdentifier> |
RMDelegationTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Token<ClientToAMTokenIdentifier> |
ClientToAMTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Modifier and Type | Method and Description |
---|---|
Token<LocalizerTokenIdentifier> |
LocalizerTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Modifier and Type | Method and Description |
---|---|
Token<LocalizerTokenIdentifier> |
LocalizerTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Modifier and Type | Method and Description |
---|---|
protected Token<AMRMTokenIdentifier> |
AMLauncher.getAMRMToken() |
Modifier and Type | Method and Description |
---|---|
Token<ClientToAMTokenIdentifier> |
RMAppAttempt.createClientToken(String clientName)
Create a token for authenticating a client connection to the app attempt
|
Token<ClientToAMTokenIdentifier> |
RMAppAttemptImpl.createClientToken(String client) |
Token<AMRMTokenIdentifier> |
RMAppAttempt.getAMRMToken()
The AMRMToken belonging to this app attempt
|
Token<AMRMTokenIdentifier> |
RMAppAttemptImpl.getAMRMToken() |
Modifier and Type | Field and Description |
---|---|
Token<?> |
DelegationTokenRenewer.DelegationTokenToRenew.token |
Modifier and Type | Method and Description |
---|---|
Set<Token<?>> |
DelegationTokenRenewer.getDelegationTokens() |
Modifier and Type | Method and Description |
---|---|
void |
AMRMTokenSecretManager.addPersistedPassword(Token<AMRMTokenIdentifier> token)
Populate persisted password of AMRMToken back to AMRMTokenSecretManager.
|
Constructor and Description |
---|
DelegationTokenRenewer.DelegationTokenToRenew(ApplicationId jId,
Token<?> token,
Configuration conf,
long expirationDate,
boolean shouldCancelAtEnd) |
Modifier and Type | Method and Description |
---|---|
static <T extends TokenIdentifier> |
ConverterUtils.convertFromYarn(Token protoToken,
InetSocketAddress serviceAddr)
Convert a protobuf token into a rpc token and set its service
|
Copyright © 2013 Apache Software Foundation. All rights reserved.