| Package | Description |
|---|---|
| org.apache.hadoop.fs |
Implementations of
AbstractFileSystem for hdfs
over rpc and hdfs over web. |
| org.apache.hadoop.fs.azure |
A distributed implementation of
FileSystem for reading and writing files on
Azure Block Storage. |
| org.apache.hadoop.fs.viewfs | |
| org.apache.hadoop.mapred | |
| org.apache.hadoop.mapreduce | |
| org.apache.hadoop.security | |
| org.apache.hadoop.security.token | |
| org.apache.hadoop.security.token.delegation | |
| org.apache.hadoop.security.token.delegation.web | |
| org.apache.hadoop.yarn.client.api |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
| org.apache.hadoop.yarn.security | |
| org.apache.hadoop.yarn.security.client | |
| org.apache.hadoop.yarn.util |
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
Token<?> |
NativeAzureFileSystem.getDelegationToken(String renewer)
Get a delegation token from remote service endpoint if
'fs.azure.enable.kerberos.support' is set to 'true'.
|
| Modifier and Type | Method and Description |
|---|---|
List<Token<?>> |
ViewFs.getDelegationTokens(String renewer) |
| Modifier and Type | Method and Description |
|---|---|
Token<org.apache.hadoop.mapreduce.security.token.delegation.DelegationTokenIdentifier> |
JobClient.getDelegationToken(Text renewer)
Get a delegation token for the user from the JobTracker.
|
| Modifier and Type | Method and Description |
|---|---|
void |
JobClient.cancelDelegationToken(Token<org.apache.hadoop.mapreduce.security.token.delegation.DelegationTokenIdentifier> token)
Deprecated.
Use
cancel(org.apache.hadoop.conf.Configuration) instead |
long |
JobClient.renewDelegationToken(Token<org.apache.hadoop.mapreduce.security.token.delegation.DelegationTokenIdentifier> token)
Deprecated.
Use
renew(org.apache.hadoop.conf.Configuration) instead |
| Modifier and Type | Method and Description |
|---|---|
Token<org.apache.hadoop.mapreduce.security.token.delegation.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<org.apache.hadoop.mapreduce.security.token.delegation.DelegationTokenIdentifier> token)
Deprecated.
Use
cancel(org.apache.hadoop.conf.Configuration) instead |
long |
Cluster.renewDelegationToken(Token<org.apache.hadoop.mapreduce.security.token.delegation.DelegationTokenIdentifier> token)
Deprecated.
Use
renew(org.apache.hadoop.conf.Configuration) instead |
| 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 | Method and Description |
|---|---|
Token<T> |
Token.privateClone(Text newService)
Create a private clone of a public token.
|
Token<T> |
TokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
| Modifier and Type | Method and Description |
|---|---|
void |
Token.TrivialRenewer.cancel(Token<?> token,
Configuration conf) |
abstract void |
TokenRenewer.cancel(Token<?> token,
Configuration conf)
Cancel the given token
|
boolean |
Token.TrivialRenewer.isManaged(Token<?> token) |
abstract boolean |
TokenRenewer.isManaged(Token<?> token)
Is the given token managed? Only managed tokens may be renewed or
cancelled.
|
long |
Token.TrivialRenewer.renew(Token<?> token,
Configuration conf) |
abstract long |
TokenRenewer.renew(Token<?> token,
Configuration conf)
Renew the given token.
|
| Modifier and Type | Method and Description |
|---|---|
Token<T> |
TokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
| Constructor and Description |
|---|
Token(Token<T> other)
Clone a token.
|
| Modifier and Type | Method and Description |
|---|---|
TokenIdent |
AbstractDelegationTokenSecretManager.cancelToken(Token<TokenIdent> token,
String canceller)
Cancel a token by removing it from cache.
|
TokenIdent |
AbstractDelegationTokenSecretManager.decodeTokenIdentifier(Token<TokenIdent> token)
Decode the token identifier.
|
long |
AbstractDelegationTokenSecretManager.renewToken(Token<TokenIdent> token,
String renewer)
Renew a delegation token.
|
| Modifier and Type | Method and Description |
|---|---|
Token<AbstractDelegationTokenIdentifier> |
DelegationTokenAuthenticatedURL.Token.getDelegationToken() |
Token<AbstractDelegationTokenIdentifier> |
DelegationTokenAuthenticator.getDelegationToken(URL url,
org.apache.hadoop.security.authentication.client.AuthenticatedURL.Token token,
String renewer)
Requests a delegation token using the configured
Authenticator
for authentication. |
Token<AbstractDelegationTokenIdentifier> |
DelegationTokenAuthenticator.getDelegationToken(URL url,
org.apache.hadoop.security.authentication.client.AuthenticatedURL.Token token,
String renewer,
String doAsUser)
Requests a delegation token using the configured
Authenticator
for authentication. |
Token<AbstractDelegationTokenIdentifier> |
DelegationTokenAuthenticatedURL.getDelegationToken(URL url,
DelegationTokenAuthenticatedURL.Token token,
String renewer)
Requests a delegation token using the configured
Authenticator
for authentication. |
Token<AbstractDelegationTokenIdentifier> |
DelegationTokenAuthenticatedURL.getDelegationToken(URL url,
DelegationTokenAuthenticatedURL.Token token,
String renewer,
String doAsUser)
Requests a delegation token using the configured
Authenticator
for authentication. |
| Modifier and Type | Method and Description |
|---|---|
void |
DelegationTokenAuthenticator.cancelDelegationToken(URL url,
org.apache.hadoop.security.authentication.client.AuthenticatedURL.Token token,
Token<AbstractDelegationTokenIdentifier> dToken)
Cancels a delegation token from the server end-point.
|
void |
DelegationTokenAuthenticator.cancelDelegationToken(URL url,
org.apache.hadoop.security.authentication.client.AuthenticatedURL.Token token,
Token<AbstractDelegationTokenIdentifier> dToken,
String doAsUser)
Cancels a delegation token from the server end-point.
|
long |
DelegationTokenAuthenticator.renewDelegationToken(URL url,
org.apache.hadoop.security.authentication.client.AuthenticatedURL.Token token,
Token<AbstractDelegationTokenIdentifier> dToken)
Renews a delegation token from the server end-point using the
configured
Authenticator for authentication. |
long |
DelegationTokenAuthenticator.renewDelegationToken(URL url,
org.apache.hadoop.security.authentication.client.AuthenticatedURL.Token token,
Token<AbstractDelegationTokenIdentifier> dToken,
String doAsUser)
Renews a delegation token from the server end-point using the
configured
Authenticator for authentication. |
void |
DelegationTokenAuthenticatedURL.Token.setDelegationToken(Token<AbstractDelegationTokenIdentifier> delegationToken) |
| Modifier and Type | Method and Description |
|---|---|
abstract Token<AMRMTokenIdentifier> |
YarnClient.getAMRMToken(ApplicationId appId)
Get the AMRM token of the application.
|
abstract Token<TimelineDelegationTokenIdentifier> |
TimelineClient.getDelegationToken(String renewer)
Get a delegation token so as to be able to talk to the timeline server in a
secure way.
|
| Modifier and Type | Method and Description |
|---|---|
abstract void |
TimelineClient.cancelDelegationToken(Token<TimelineDelegationTokenIdentifier> timelineDT)
Cancel a timeline delegation token.
|
abstract long |
TimelineClient.renewDelegationToken(Token<TimelineDelegationTokenIdentifier> timelineDT)
Renew a timeline delegation token.
|
| Modifier and Type | Method and Description |
|---|---|
Token<AMRMTokenIdentifier> |
AMRMTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Token<ContainerTokenIdentifier> |
ContainerTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
| Modifier and Type | Method and Description |
|---|---|
Token<AMRMTokenIdentifier> |
AMRMTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Token<ContainerTokenIdentifier> |
ContainerTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
| Modifier and Type | Method and Description |
|---|---|
Token<TimelineDelegationTokenIdentifier> |
TimelineDelegationTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Token<RMDelegationTokenIdentifier> |
RMDelegationTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
| Modifier and Type | Method and Description |
|---|---|
Token<TimelineDelegationTokenIdentifier> |
TimelineDelegationTokenSelector.selectToken(Text service,
Collection<Token<? extends TokenIdentifier>> tokens) |
Token<RMDelegationTokenIdentifier> |
RMDelegationTokenSelector.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.
|
static <T extends TokenIdentifier> |
ConverterUtils.convertFromYarn(Token protoToken,
Text service)
Convert a protobuf token into a rpc token and set its service.
|
Copyright © 2019 Apache Software Foundation. All rights reserved.