Modifier and Type | Method and Description |
---|---|
<T extends TokenIdentifier> |
DelegationTokenRenewer.Renewable.setDelegationToken(Token<T> token)
Set delegation token.
|
Modifier and Type | Method and Description |
---|---|
<T extends TokenIdentifier> |
HttpFSFileSystem.setDelegationToken(Token<T> token) |
Modifier and Type | Method and Description |
---|---|
<T extends TokenIdentifier> |
HftpFileSystem.setDelegationToken(Token<T> token) |
Modifier and Type | Class and Description |
---|---|
class |
BlockTokenIdentifier |
Modifier and Type | Method and Description |
---|---|
Token<BlockTokenIdentifier> |
BlockTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Modifier and Type | Class and Description |
---|---|
class |
DelegationTokenIdentifier
A delegation token identifier that is specific to HDFS.
|
Modifier and Type | Method and Description |
---|---|
<T extends TokenIdentifier> |
WebHdfsFileSystem.setDelegationToken(Token<T> token) |
Modifier and Type | Method and Description |
---|---|
static Token<? extends TokenIdentifier> |
JsonUtil.toToken(Map<?,?> m)
Convert a Json map to a Token.
|
Modifier and Type | Method and Description |
---|---|
static String |
JsonUtil.toJsonString(Token<? extends TokenIdentifier> token)
Convert a token object to a Json string.
|
Modifier and Type | Method and Description |
---|---|
RPC.Server |
WritableRpcEngine.getServer(Class<?> protocolClass,
Object protocolImpl,
String bindAddress,
int port,
int numHandlers,
int numReaders,
int queueSizePerHandler,
boolean verbose,
Configuration conf,
SecretManager<? extends TokenIdentifier> secretManager,
String portRangeConfig) |
RPC.Server |
ProtobufRpcEngine.getServer(Class<?> protocol,
Object protocolImpl,
String bindAddress,
int port,
int numHandlers,
int numReaders,
int queueSizePerHandler,
boolean verbose,
Configuration conf,
SecretManager<? extends TokenIdentifier> secretManager,
String portRangeConfig) |
RPC.Server |
RpcEngine.getServer(Class<?> protocol,
Object instance,
String bindAddress,
int port,
int numHandlers,
int numReaders,
int queueSizePerHandler,
boolean verbose,
Configuration conf,
SecretManager<? extends TokenIdentifier> secretManager,
String portRangeConfig)
Construct a server for a protocol implementation instance.
|
RPC.Builder |
RPC.Builder.setSecretManager(SecretManager<? extends TokenIdentifier> secretManager)
Default: null
|
Constructor and Description |
---|
ProtobufRpcEngine.Server(Class<?> protocolClass,
Object protocolImpl,
Configuration conf,
String bindAddress,
int port,
int numHandlers,
int numReaders,
int queueSizePerHandler,
boolean verbose,
SecretManager<? extends TokenIdentifier> secretManager,
String portRangeConfig)
Construct an RPC server.
|
RPC.Server(String bindAddress,
int port,
Class<? extends Writable> paramClass,
int handlerCount,
int numReaders,
int queueSizePerHandler,
Configuration conf,
String serverName,
SecretManager<? extends TokenIdentifier> secretManager,
String portRangeConfig) |
Server(String bindAddress,
int port,
Class<? extends Writable> rpcRequestClass,
int handlerCount,
int numReaders,
int queueSizePerHandler,
Configuration conf,
String serverName,
SecretManager<? extends TokenIdentifier> secretManager) |
Server(String bindAddress,
int port,
Class<? extends Writable> rpcRequestClass,
int handlerCount,
int numReaders,
int queueSizePerHandler,
Configuration conf,
String serverName,
SecretManager<? extends TokenIdentifier> secretManager,
String portRangeConfig)
Constructs a server listening on the named port and address.
|
WritableRpcEngine.Server(Class<?> protocolClass,
Object protocolImpl,
Configuration conf,
String bindAddress,
int port,
int numHandlers,
int numReaders,
int queueSizePerHandler,
boolean verbose,
SecretManager<? extends TokenIdentifier> secretManager,
String portRangeConfig)
Construct an RPC server.
|
WritableRpcEngine.Server(Object protocolImpl,
Configuration conf,
String bindAddress,
int port,
int numHandlers,
int numReaders,
int queueSizePerHandler,
boolean verbose,
SecretManager<? extends TokenIdentifier> secretManager)
Deprecated.
use Server#Server(Class, Object,
Configuration, String, int, int, int, int, boolean, SecretManager)
|
Modifier and Type | Method and Description |
---|---|
static void |
TokenCache.setJobToken(Token<? extends TokenIdentifier> t,
Credentials credentials)
store job token
|
Modifier and Type | Class and Description |
---|---|
class |
JobTokenIdentifier
The token identifier for job token
|
Modifier and Type | Method and Description |
---|---|
Token<JobTokenIdentifier> |
JobTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Modifier and Type | Class and Description |
---|---|
class |
MRDelegationTokenIdentifier
TokenIdentifier that identifies delegation tokens
issued by JobHistoryServer to delegate
MR tasks talking to the JobHistoryServer. |
Modifier and Type | Method and Description |
---|---|
Token<MRDelegationTokenIdentifier> |
ClientHSTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Modifier and Type | Method and Description |
---|---|
static <T extends TokenIdentifier> |
SaslRpcServer.getIdentifier(String id,
SecretManager<T> secretManager) |
Modifier and Type | Method and Description |
---|---|
Collection<Token<? extends TokenIdentifier>> |
Credentials.getAllTokens()
Return all the tokens in the in-memory map
|
Token<? extends TokenIdentifier> |
Credentials.getToken(Text alias)
Returns the Token object for the alias
|
Set<TokenIdentifier> |
UserGroupInformation.getTokenIdentifiers()
Get the set of TokenIdentifiers belonging to this UGI
|
Collection<Token<? extends TokenIdentifier>> |
UserGroupInformation.getTokens()
Obtain the collection of tokens associated with this user.
|
Modifier and Type | Method and Description |
---|---|
boolean |
UserGroupInformation.addTokenIdentifier(TokenIdentifier tokenId)
Add a TokenIdentifier to this UGI.
|
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
|
SaslServer |
SaslRpcServer.create(Server.Connection connection,
SecretManager<TokenIdentifier> secretManager) |
Constructor and Description |
---|
SaslRpcServer.SaslDigestCallbackHandler(SecretManager<TokenIdentifier> secretManager,
Server.Connection connection) |
Modifier and Type | Class and Description |
---|---|
class |
SecretManager<T extends TokenIdentifier>
The server-side secret manager for each token type.
|
class |
Token<T extends TokenIdentifier>
The client-side form of the token.
|
static class |
Token.PrivateToken<T extends TokenIdentifier>
Indicates whether the token is a clone.
|
interface |
TokenSelector<T extends TokenIdentifier>
Select token of type T from tokens for use with named service
|
Modifier and Type | Method and Description |
---|---|
Token<T> |
TokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractDelegationTokenIdentifier |
Modifier and Type | Method and Description |
---|---|
Token<TokenIdent> |
AbstractDelegationTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Modifier and Type | Method and Description |
---|---|
Server |
RpcServerFactory.getServer(Class<?> protocol,
Object instance,
InetSocketAddress addr,
Configuration conf,
SecretManager<? extends TokenIdentifier> secretManager,
int numHandlers,
String portRangeConfig) |
Modifier and Type | Method and Description |
---|---|
Server |
RpcServerFactoryPBImpl.getServer(Class<?> protocol,
Object instance,
InetSocketAddress addr,
Configuration conf,
SecretManager<? extends TokenIdentifier> secretManager,
int numHandlers) |
Server |
RpcServerFactoryPBImpl.getServer(Class<?> protocol,
Object instance,
InetSocketAddress addr,
Configuration conf,
SecretManager<? extends TokenIdentifier> secretManager,
int numHandlers,
String portRangeConfig) |
Modifier and Type | Method and Description |
---|---|
Server |
YarnRPC.getServer(Class protocol,
Object instance,
InetSocketAddress addr,
Configuration conf,
SecretManager<? extends TokenIdentifier> secretManager,
int numHandlers) |
abstract Server |
YarnRPC.getServer(Class protocol,
Object instance,
InetSocketAddress addr,
Configuration conf,
SecretManager<? extends TokenIdentifier> secretManager,
int numHandlers,
String portRangeConfig) |
Server |
HadoopYarnProtoRPC.getServer(Class protocol,
Object instance,
InetSocketAddress addr,
Configuration conf,
SecretManager<? extends TokenIdentifier> secretManager,
int numHandlers,
String portRangeConfig) |
Modifier and Type | Class and Description |
---|---|
class |
AMRMTokenIdentifier
AMRMTokenIdentifier is the TokenIdentifier to be used by
ApplicationMasters to authenticate to the ResourceManager.
|
class |
ContainerTokenIdentifier
TokenIdentifier for a container.
|
class |
NMTokenIdentifier |
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 | Class and Description |
---|---|
class |
ClientToAMTokenIdentifier |
class |
RMDelegationTokenIdentifier
Delegation Token Identifier that identifies the delegation tokens from the
Resource Manager.
|
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 | Class and Description |
---|---|
class |
LocalizerTokenIdentifier |
Modifier and Type | Method and Description |
---|---|
Token<LocalizerTokenIdentifier> |
LocalizerTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
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.