Package | Description |
---|---|
org.apache.hadoop.yarn.api.protocolrecords |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
org.apache.hadoop.yarn.api.records |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
Modifier and Type | Method and Description |
---|---|
abstract Token |
AllocateResponse.getAMRMToken()
The AMRMToken that belong to this attempt
|
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 |
---|---|
abstract List<Token> |
IncreaseContainersResourceRequest.getContainersToIncrease()
Get a list of container tokens to be used for authorization during
container resource increase.
|
abstract List<Token> |
ContainerUpdateRequest.getContainersToUpdate()
Get a list of container tokens to be used for authorization during
container resource update.
|
Modifier and Type | Method and Description |
---|---|
AllocateResponse.AllocateResponseBuilder |
AllocateResponse.AllocateResponseBuilder.amRmToken(Token amRmToken)
Set the
amRmToken of the response. |
static StartContainerRequest |
StartContainerRequest.newInstance(ContainerLaunchContext context,
Token container) |
static AllocateResponse |
AllocateResponse.newInstance(int responseId,
List<ContainerStatus> completedContainers,
List<Container> allocatedContainers,
List<NodeReport> updatedNodes,
Resource availResources,
AMCommand command,
int numClusterNodes,
PreemptionMessage preempt,
List<NMToken> nmTokens,
Token amRMToken,
List<UpdatedContainer> updatedContainers) |
static AllocateResponse |
AllocateResponse.newInstance(int responseId,
List<ContainerStatus> completedContainers,
List<Container> allocatedContainers,
List<NodeReport> updatedNodes,
Resource availResources,
AMCommand command,
int numClusterNodes,
PreemptionMessage preempt,
List<NMToken> nmTokens,
Token amRMToken,
List<UpdatedContainer> updatedContainers,
CollectorInfo collectorInfo) |
static AllocateResponse |
AllocateResponse.newInstance(int responseId,
List<ContainerStatus> completedContainers,
List<Container> allocatedContainers,
List<NodeReport> updatedNodes,
Resource availResources,
AMCommand command,
int numClusterNodes,
PreemptionMessage preempt,
List<NMToken> nmTokens,
Token amRMToken,
List<UpdatedContainer> updatedContainers,
CollectorInfo collectorInfo,
EnhancedHeadroom enhancedHeadroom) |
static RenewDelegationTokenRequest |
RenewDelegationTokenRequest.newInstance(Token dToken) |
static CancelDelegationTokenRequest |
CancelDelegationTokenRequest.newInstance(Token dToken) |
static GetDelegationTokenResponse |
GetDelegationTokenResponse.newInstance(Token rmDTToken) |
abstract void |
AllocateResponse.setAMRMToken(Token amRMToken) |
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 |
---|---|
static ContainerUpdateRequest |
ContainerUpdateRequest.newInstance(List<Token> containersToIncrease) |
static IncreaseContainersResourceRequest |
IncreaseContainersResourceRequest.newInstance(List<Token> containersToIncrease) |
abstract void |
IncreaseContainersResourceRequest.setContainersToIncrease(List<Token> containersToIncrease)
Set container tokens to be used during container resource increase.
|
abstract void |
ContainerUpdateRequest.setContainersToUpdate(List<Token> containersToUpdate)
Set container tokens to be used during container resource increase.
|
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 |
CollectorInfo.getCollectorToken()
Get delegation token for app collector which AM will use to publish
entities.
|
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,
Set<String> tags,
boolean unmanagedApplication,
Priority priority,
String appNodeLabelExpression,
String amNodeLabelExpression) |
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 launchTime,
long finishTime,
FinalApplicationStatus finalStatus,
ApplicationResourceUsageReport appResources,
String origTrackingUrl,
float progress,
String applicationType,
Token amRmToken) |
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 launchTime,
long finishTime,
FinalApplicationStatus finalStatus,
ApplicationResourceUsageReport appResources,
String origTrackingUrl,
float progress,
String applicationType,
Token amRmToken,
Set<String> tags,
boolean unmanagedApplication,
Priority priority,
String appNodeLabelExpression,
String amNodeLabelExpression) |
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 submitTime,
long launchTime,
long finishTime,
FinalApplicationStatus finalStatus,
ApplicationResourceUsageReport appResources,
String origTrackingUrl,
float progress,
String applicationType,
Token amRmToken) |
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 submitTime,
long launchTime,
long finishTime,
FinalApplicationStatus finalStatus,
ApplicationResourceUsageReport appResources,
String origTrackingUrl,
float progress,
String applicationType,
Token amRmToken,
Set<String> tags,
boolean unmanagedApplication,
Priority priority,
String appNodeLabelExpression,
String amNodeLabelExpression) |
static Container |
Container.newInstance(ContainerId containerId,
NodeId nodeId,
String nodeHttpAddress,
Resource resource,
Priority priority,
Token containerToken) |
static Container |
Container.newInstance(ContainerId containerId,
NodeId nodeId,
String nodeHttpAddress,
Resource resource,
Priority priority,
Token containerToken,
ExecutionType executionType) |
static NMToken |
NMToken.newInstance(NodeId nodeId,
Token token) |
static CollectorInfo |
CollectorInfo.newInstance(String collectorAddr,
Token token) |
abstract void |
ApplicationReport.setAMRMToken(Token amRmToken) |
abstract void |
ApplicationReport.setClientToAMToken(Token clientToAMToken) |
abstract void |
CollectorInfo.setCollectorToken(Token token) |
abstract void |
Container.setContainerToken(Token containerToken) |
abstract void |
NMToken.setToken(Token token) |
Copyright © 2008–2024 Apache Software Foundation. All rights reserved.