程序包 | 说明 |
---|---|
org.apache.hadoop.fs |
An abstract file system API.
|
org.apache.hadoop.hdfs |
A distributed implementation of
FileSystem . |
org.apache.hadoop.hdfs.protocol | |
org.apache.hadoop.hdfs.security.token.block | |
org.apache.hadoop.hdfs.security.token.delegation | |
org.apache.hadoop.hdfs.server.datanode | |
org.apache.hadoop.hdfs.server.namenode | |
org.apache.hadoop.hdfs.tools | |
org.apache.hadoop.hdfs.web | |
org.apache.hadoop.mapred |
A software framework for easily writing applications which process vast
amounts of data (multi-terabyte data-sets) parallelly on large clusters
(thousands of nodes) built of commodity hardware in a reliable, fault-tolerant
manner.
|
org.apache.hadoop.mapreduce.security | |
org.apache.hadoop.mapreduce.security.token | |
org.apache.hadoop.security | |
org.apache.hadoop.security.token | |
org.apache.hadoop.security.token.delegation |
限定符和类型 | 方法和说明 |
---|---|
Token<?> |
FileSystem.getDelegationToken(String renewer)
Get a new delegation token for this file system.
|
限定符和类型 | 方法和说明 |
---|---|
Token<?> |
HftpFileSystem.getDelegationToken(String renewer) |
Token<DelegationTokenIdentifier> |
DistributedFileSystem.getDelegationToken(String renewer) |
Token<DelegationTokenIdentifier> |
DistributedFileSystem.getDelegationToken(Text renewer)
已过时。
|
Token<DelegationTokenIdentifier> |
DFSClient.getDelegationToken(Text renewer) |
Token<?> |
HftpFileSystem.getRenewToken() |
protected Token<DelegationTokenIdentifier> |
HftpFileSystem.selectHdfsDelegationToken() |
protected Token<DelegationTokenIdentifier> |
HsftpFileSystem.selectHftpDelegationToken() |
protected Token<DelegationTokenIdentifier> |
HftpFileSystem.selectHftpDelegationToken() |
限定符和类型 | 方法和说明 |
---|---|
void |
HftpFileSystem.TokenManager.cancel(Token<?> token,
Configuration conf) |
void |
DFSClient.Renewer.cancel(Token<?> token,
Configuration conf) |
void |
DistributedFileSystem.cancelDelegationToken(Token<DelegationTokenIdentifier> token)
已过时。
Use Token.cancel instead.
|
void |
DFSClient.cancelDelegationToken(Token<DelegationTokenIdentifier> token)
已过时。
Use Token.cancel instead.
|
boolean |
HftpFileSystem.TokenManager.isManaged(Token<?> token) |
boolean |
DFSClient.Renewer.isManaged(Token<?> token) |
static BlockReader |
DFSClient.RemoteBlockReader.newBlockReader(Socket sock,
String file,
long blockId,
Token<BlockTokenIdentifier> accessToken,
long genStamp,
long startOffset,
long len,
int bufferSize) |
static BlockReader |
DFSClient.RemoteBlockReader.newBlockReader(Socket sock,
String file,
long blockId,
Token<BlockTokenIdentifier> accessToken,
long genStamp,
long startOffset,
long len,
int bufferSize,
boolean verifyChecksum)
Creates a new
BlockReader for the given blockId. |
static BlockReader |
DFSClient.RemoteBlockReader.newBlockReader(Socket sock,
String file,
long blockId,
Token<BlockTokenIdentifier> accessToken,
long genStamp,
long startOffset,
long len,
int bufferSize,
boolean verifyChecksum,
String clientName) |
long |
HftpFileSystem.TokenManager.renew(Token<?> token,
Configuration conf) |
long |
DFSClient.Renewer.renew(Token<?> token,
Configuration conf) |
long |
DistributedFileSystem.renewDelegationToken(Token<DelegationTokenIdentifier> token)
已过时。
Use Token.renew instead.
|
long |
DFSClient.renewDelegationToken(Token<DelegationTokenIdentifier> token)
已过时。
Use Token.renew instead.
|
<T extends TokenIdentifier> |
HftpFileSystem.setDelegationToken(Token<T> token) |
static String |
DFSClient.stringifyToken(Token<DelegationTokenIdentifier> token)
A test method for printing out tokens
|
限定符和类型 | 方法和说明 |
---|---|
Token<BlockTokenIdentifier> |
LocatedBlock.getBlockToken() |
Token<DelegationTokenIdentifier> |
ClientProtocol.getDelegationToken(Text renewer)
Get a valid Delegation Token.
|
限定符和类型 | 方法和说明 |
---|---|
void |
ClientProtocol.cancelDelegationToken(Token<DelegationTokenIdentifier> token)
Cancel an existing delegation token.
|
BlockLocalPathInfo |
ClientDatanodeProtocol.getBlockLocalPathInfo(Block 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) |
限定符和类型 | 字段和说明 |
---|---|
static Token<BlockTokenIdentifier> |
BlockTokenSecretManager.DUMMY_TOKEN |
限定符和类型 | 方法和说明 |
---|---|
Token<BlockTokenIdentifier> |
BlockTokenSecretManager.generateToken(Block block,
EnumSet<BlockTokenSecretManager.AccessMode> modes)
Generate an block token for current user
|
Token<BlockTokenIdentifier> |
BlockTokenSecretManager.generateToken(long[] blockIds,
EnumSet<BlockTokenSecretManager.AccessMode> modes)
Generate a block token for the current user based on a collection
of blockIds
|
Token<BlockTokenIdentifier> |
BlockTokenSecretManager.generateToken(String userId,
Block block,
EnumSet<BlockTokenSecretManager.AccessMode> modes)
Generate a block token for a specified user
|
Token<BlockTokenIdentifier> |
BlockTokenSecretManager.generateToken(String userID,
long[] blockIds,
EnumSet<BlockTokenSecretManager.AccessMode> modes)
Generate a block token based on a collection of blockIds
|
Token<BlockTokenIdentifier> |
BlockTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
限定符和类型 | 方法和说明 |
---|---|
void |
BlockTokenSecretManager.checkAccess(Token<BlockTokenIdentifier> token,
String userId,
Block block,
BlockTokenSecretManager.AccessMode mode)
Check if access should be allowed. userID is not checked if null
|
限定符和类型 | 方法和说明 |
---|---|
Token<BlockTokenIdentifier> |
BlockTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
限定符和类型 | 方法和说明 |
---|---|
Token<?> |
DelegationTokenRenewer.Renewable.getRenewToken() |
static Token<DelegationTokenIdentifier> |
DelegationTokenSelector.selectHdfsDelegationToken(InetSocketAddress nnAddr,
UserGroupInformation ugi,
Configuration conf)
Select the delegation token for hdfs from the ugi.
|
限定符和类型 | 方法和说明 |
---|---|
<T extends TokenIdentifier> |
DelegationTokenRenewer.Renewable.setDelegationToken(Token<T> token)
Set delegation token.
|
限定符和类型 | 方法和说明 |
---|---|
BlockLocalPathInfo |
DataNode.getBlockLocalPathInfo(Block block,
Token<BlockTokenIdentifier> token) |
限定符和类型 | 方法和说明 |
---|---|
Token<DelegationTokenIdentifier> |
NameNode.getDelegationToken(Text renewer) |
Token<DelegationTokenIdentifier> |
FSNamesystem.getDelegationToken(Text renewer) |
限定符和类型 | 方法和说明 |
---|---|
void |
NameNode.cancelDelegationToken(Token<DelegationTokenIdentifier> token) |
void |
FSNamesystem.cancelDelegationToken(Token<DelegationTokenIdentifier> token) |
long |
NameNode.renewDelegationToken(Token<DelegationTokenIdentifier> token) |
long |
FSNamesystem.renewDelegationToken(Token<DelegationTokenIdentifier> token) |
void |
JspHelper.streamBlockInAscii(InetSocketAddress addr,
long blockId,
Token<BlockTokenIdentifier> accessToken,
long genStamp,
long blockSize,
long offsetIntoBlock,
long chunkSizeToView,
javax.servlet.jsp.JspWriter out,
Configuration conf) |
限定符和类型 | 方法和说明 |
---|---|
static void |
DelegationTokenFetcher.cancelDelegationToken(String protocol,
InetSocketAddress addr,
Token<DelegationTokenIdentifier> tok,
Configuration conf)
Cancel a Delegation Token.
|
static long |
DelegationTokenFetcher.renewDelegationToken(String protocol,
InetSocketAddress addr,
Token<DelegationTokenIdentifier> tok,
Configuration conf)
Renew a Delegation Token.
|
限定符和类型 | 方法和说明 |
---|---|
Token<DelegationTokenIdentifier> |
WebHdfsFileSystem.getDelegationToken(String renewer) |
Token<?> |
WebHdfsFileSystem.getRenewToken() |
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.
|
限定符和类型 | 方法和说明 |
---|---|
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.
|
限定符和类型 | 方法和说明 |
---|---|
Token<DelegationTokenIdentifier> |
LocalJobRunner.getDelegationToken(Text renewer) |
Token<DelegationTokenIdentifier> |
JobTracker.getDelegationToken(Text renewer)
Get a new delegation token.
|
Token<DelegationTokenIdentifier> |
JobClient.getDelegationToken(Text renewer) |
限定符和类型 | 方法和说明 |
---|---|
void |
JobClient.Renewer.cancel(Token<?> token,
Configuration conf) |
void |
LocalJobRunner.cancelDelegationToken(Token<DelegationTokenIdentifier> token) |
void |
JobTracker.cancelDelegationToken(Token<DelegationTokenIdentifier> token)
Discard a current delegation token.
|
void |
JobClient.cancelDelegationToken(Token<DelegationTokenIdentifier> token)
Cancel a delegation token from the JobTracker
|
boolean |
JobClient.Renewer.isManaged(Token<?> token) |
long |
JobClient.Renewer.renew(Token<?> token,
Configuration conf) |
long |
LocalJobRunner.renewDelegationToken(Token<DelegationTokenIdentifier> token) |
long |
JobTracker.renewDelegationToken(Token<DelegationTokenIdentifier> token)
Renew a delegation token to extend its lifetime.
|
long |
JobClient.renewDelegationToken(Token<DelegationTokenIdentifier> token)
Renew a delegation token
|
限定符和类型 | 方法和说明 |
---|---|
static Token<DelegationTokenIdentifier> |
TokenCache.getDelegationToken(Credentials credentials,
String namenode) |
static Token<JobTokenIdentifier> |
TokenCache.getJobToken(Credentials credentials) |
限定符和类型 | 方法和说明 |
---|---|
static void |
TokenCache.setJobToken(Token<? extends TokenIdentifier> t,
Credentials credentials)
store job token
|
限定符和类型 | 方法和说明 |
---|---|
Token<JobTokenIdentifier> |
JobTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
限定符和类型 | 方法和说明 |
---|---|
void |
JobTokenSecretManager.addTokenForJob(String jobId,
Token<JobTokenIdentifier> token)
Add the job token of a job to cache
|
限定符和类型 | 方法和说明 |
---|---|
Token<JobTokenIdentifier> |
JobTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
限定符和类型 | 方法和说明 |
---|---|
Token<? extends TokenIdentifier> |
Credentials.getToken(Text alias)
Returns the Token object for the alias
|
限定符和类型 | 方法和说明 |
---|---|
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.
|
限定符和类型 | 方法和说明 |
---|---|
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
|
构造器和说明 |
---|
SaslRpcClient(SaslRpcServer.AuthMethod method,
Token<? extends TokenIdentifier> token,
String serverPrincipal,
boolean fallbackAllowed)
Create a SaslRpcClient for an authentication method
|
限定符和类型 | 方法和说明 |
---|---|
Token<T> |
TokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
限定符和类型 | 方法和说明 |
---|---|
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?
|
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) |
限定符和类型 | 方法和说明 |
---|---|
Token<T> |
TokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
构造器和说明 |
---|
Token(Token<T> other)
Clone a token.
|
限定符和类型 | 方法和说明 |
---|---|
Token<TokenIdent> |
AbstractDelegationTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
限定符和类型 | 方法和说明 |
---|---|
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.
|
限定符和类型 | 方法和说明 |
---|---|
Token<TokenIdent> |
AbstractDelegationTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Copyright © 2009 The Apache Software Foundation