Modifier and Type | Method and Description |
---|---|
Token |
ResourceMgrDelegate.getRMDelegationToken(Text renewer) |
Modifier and Type | Method and Description |
---|---|
Token |
RenewDelegationTokenRequest.getDelegationToken() |
Token |
GetDelegationTokenResponse.getDelegationToken() |
Token |
CancelDelegationTokenRequest.getDelegationToken() |
Modifier and Type | Method and Description |
---|---|
void |
RenewDelegationTokenRequest.setDelegationToken(Token dToken) |
void |
GetDelegationTokenResponse.setDelegationToken(Token clientDToken) |
void |
CancelDelegationTokenRequest.setDelegationToken(Token dToken) |
Modifier and Type | Method and Description |
---|---|
Token |
RenewDelegationTokenRequestPBImpl.getDelegationToken() |
Token |
CancelDelegationTokenRequestPBImpl.getDelegationToken() |
Token |
GetDelegationTokenResponsePBImpl.getDelegationToken() |
Modifier and Type | Method and Description |
---|---|
void |
RenewDelegationTokenRequestPBImpl.setDelegationToken(Token token) |
void |
CancelDelegationTokenRequestPBImpl.setDelegationToken(Token token) |
void |
GetDelegationTokenResponsePBImpl.setDelegationToken(Token mrToken) |
Modifier and Type | Method and Description |
---|---|
Token |
ContainerLauncherEvent.getContainerToken() |
Constructor and Description |
---|
ContainerLauncherEvent(TaskAttemptId taskAttemptID,
ContainerId containerID,
String containerMgrAddress,
Token containerToken,
ContainerLauncher.EventType type) |
Modifier and Type | Method and Description |
---|---|
abstract Token |
StartContainerRequest.getContainerToken()
Get the container token to be used for authorization during starting
container.
|
abstract Token |
RenewDelegationTokenRequest.getDelegationToken()
Get the delegation token requested to be renewed by the client.
|
abstract Token |
CancelDelegationTokenRequest.getDelegationToken()
Get the delegation token requested to be cancelled.
|
abstract Token |
GetDelegationTokenResponse.getRMDelegationToken()
The Delegation tokens have a identifier which maps to
AbstractDelegationTokenIdentifier . |
Modifier and Type | Method and Description |
---|---|
static StartContainerRequest |
StartContainerRequest.newInstance(ContainerLaunchContext context,
Token container) |
static RenewDelegationTokenRequest |
RenewDelegationTokenRequest.newInstance(Token dToken) |
static GetDelegationTokenResponse |
GetDelegationTokenResponse.newInstance(Token rmDTToken) |
static CancelDelegationTokenRequest |
CancelDelegationTokenRequest.newInstance(Token dToken) |
abstract void |
StartContainerRequest.setContainerToken(Token container) |
abstract void |
RenewDelegationTokenRequest.setDelegationToken(Token dToken) |
abstract void |
CancelDelegationTokenRequest.setDelegationToken(Token dToken) |
abstract void |
GetDelegationTokenResponse.setRMDelegationToken(Token rmDTToken) |
Modifier and Type | Method and Description |
---|---|
Token |
StartContainerRequestPBImpl.getContainerToken() |
Token |
RenewDelegationTokenRequestPBImpl.getDelegationToken() |
Token |
CancelDelegationTokenRequestPBImpl.getDelegationToken() |
Token |
GetDelegationTokenResponsePBImpl.getRMDelegationToken() |
Modifier and Type | Method and Description |
---|---|
void |
StartContainerRequestPBImpl.setContainerToken(Token containerToken) |
void |
RenewDelegationTokenRequestPBImpl.setDelegationToken(Token token) |
void |
CancelDelegationTokenRequestPBImpl.setDelegationToken(Token token) |
void |
GetDelegationTokenResponsePBImpl.setRMDelegationToken(Token appToken) |
Modifier and Type | Method and Description |
---|---|
abstract Token |
ApplicationReport.getAMRMToken()
Get the AMRM token of the application.
|
abstract Token |
ApplicationReport.getClientToAMToken()
Get the client token for communicating with the
ApplicationMaster . |
abstract Token |
Container.getContainerToken()
Get the
ContainerToken for the container. |
abstract Token |
NMToken.getToken()
Get the
Token used for authenticating with NodeManager |
static Token |
Token.newInstance(byte[] identifier,
String kind,
byte[] password,
String service) |
Modifier and Type | Method and Description |
---|---|
static ApplicationReport |
ApplicationReport.newInstance(ApplicationId applicationId,
ApplicationAttemptId applicationAttemptId,
String user,
String queue,
String name,
String host,
int rpcPort,
Token clientToAMToken,
YarnApplicationState state,
String diagnostics,
String url,
long startTime,
long finishTime,
FinalApplicationStatus finalStatus,
ApplicationResourceUsageReport appResources,
String origTrackingUrl,
float progress,
String applicationType,
Token amRmToken) |
static Container |
Container.newInstance(ContainerId containerId,
NodeId nodeId,
String nodeHttpAddress,
Resource resource,
Priority priority,
Token containerToken) |
static NMToken |
NMToken.newInstance(NodeId nodeId,
Token token) |
abstract void |
ApplicationReport.setAMRMToken(Token amRmToken) |
abstract void |
ApplicationReport.setClientToAMToken(Token clientToAMToken) |
abstract void |
Container.setContainerToken(Token containerToken) |
abstract void |
NMToken.setToken(Token token) |
Modifier and Type | Class and Description |
---|---|
class |
TokenPBImpl |
Modifier and Type | Method and Description |
---|---|
Token |
ApplicationReportPBImpl.getAMRMToken() |
Token |
ApplicationReportPBImpl.getClientToAMToken() |
Token |
ContainerPBImpl.getContainerToken() |
Token |
NMTokenPBImpl.getToken() |
Modifier and Type | Method and Description |
---|---|
void |
ApplicationReportPBImpl.setAMRMToken(Token amRmToken) |
void |
ApplicationReportPBImpl.setClientToAMToken(Token clientToAMToken) |
void |
ContainerPBImpl.setContainerToken(Token containerToken) |
void |
NMTokenPBImpl.setToken(Token token) |
Modifier and Type | Method and Description |
---|---|
static Token |
NMTokenCache.getNMToken(String nodeAddr)
Returns NMToken, null if absent
|
abstract Token |
YarnClient.getRMDelegationToken(Text renewer)
Get a delegation token so as to be able to talk to YARN using those tokens.
|
Modifier and Type | Method and Description |
---|---|
static void |
NMTokenCache.setNMToken(String nodeAddr,
Token token)
Sets the NMToken for node address
|
Modifier and Type | Method and Description |
---|---|
Token |
NMClientAsyncImpl.ContainerEvent.getContainerToken() |
Constructor and Description |
---|
NMClientAsyncImpl.ContainerEvent(ContainerId containerId,
NodeId nodeId,
Token containerToken,
NMClientAsyncImpl.ContainerEventType type) |
Modifier and Type | Method and Description |
---|---|
Token |
YarnClientImpl.getRMDelegationToken(Text renewer) |
Modifier and Type | Method and Description |
---|---|
protected ContainerManagementProtocol |
ContainerManagementProtocolProxy.ContainerManagementProtocolProxyData.newProxy(YarnRPC rpc,
String containerManagerBindAddr,
ContainerId containerId,
Token token) |
Constructor and Description |
---|
ContainerManagementProtocolProxy.ContainerManagementProtocolProxyData(YarnRPC rpc,
String containerManagerBindAddr,
ContainerId containerId,
Token token) |
NMClientImpl.StartedContainer(ContainerId containerId,
NodeId nodeId,
Token containerToken) |
Modifier and Type | Method and Description |
---|---|
protected ContainerTokenIdentifier |
ContainerManagerImpl.verifyAndGetContainerTokenIdentifier(Token token,
ContainerTokenIdentifier containerTokenIdentifier) |
Modifier and Type | Method and Description |
---|---|
Token |
RMContainerTokenSecretManager.createContainerToken(ContainerId containerId,
NodeId nodeId,
String appSubmitter,
Resource capability)
Helper function for creating ContainerTokens
|
Modifier and Type | Method and Description |
---|---|
Token |
BaseNMTokenSecretManager.createNMToken(ApplicationAttemptId applicationAttemptId,
NodeId nodeId,
String applicationSubmitter)
Helper function for creating NMTokens.
|
static Token |
BaseNMTokenSecretManager.newInstance(byte[] password,
NMTokenIdentifier identifier) |
Modifier and Type | Method and Description |
---|---|
static <T extends Token> |
BuilderUtils.newToken(Class<T> tokenClass,
byte[] identifier,
String kind,
byte[] password,
String service) |
Modifier and Type | Method and Description |
---|---|
static Token |
BuilderUtils.newAMRMToken(byte[] identifier,
String kind,
byte[] password,
String service) |
static Token |
BuilderUtils.newClientToAMToken(byte[] identifier,
String kind,
byte[] password,
String service) |
static Token |
BuilderUtils.newContainerToken(ContainerId cId,
String host,
int port,
String user,
Resource r,
long expiryTime,
int masterKeyId,
byte[] password,
long rmIdentifier) |
static Token |
BuilderUtils.newContainerToken(NodeId nodeId,
byte[] password,
ContainerTokenIdentifier tokenIdentifier) |
static Token |
BuilderUtils.newDelegationToken(byte[] identifier,
String kind,
byte[] password,
String service) |
Modifier and Type | Method and Description |
---|---|
static ApplicationReport |
BuilderUtils.newApplicationReport(ApplicationId applicationId,
ApplicationAttemptId applicationAttemptId,
String user,
String queue,
String name,
String host,
int rpcPort,
Token clientToAMToken,
YarnApplicationState state,
String diagnostics,
String url,
long startTime,
long finishTime,
FinalApplicationStatus finalStatus,
ApplicationResourceUsageReport appResources,
String origTrackingUrl,
float progress,
String appType,
Token amRmToken) |
static Container |
BuilderUtils.newContainer(ContainerId containerId,
NodeId nodeId,
String nodeHttpAddress,
Resource resource,
Priority priority,
Token containerToken) |
static ContainerTokenIdentifier |
BuilderUtils.newContainerTokenIdentifier(Token containerToken) |
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.