@InterfaceAudience.Private @InterfaceStability.Unstable public class AppSchedulingInfo extends Object
Constructor and Description |
---|
AppSchedulingInfo(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId,
String user,
Queue queue,
ActiveUsersManager activeUsersManager,
long epoch) |
Modifier and Type | Method and Description |
---|---|
List<org.apache.hadoop.yarn.api.records.ResourceRequest> |
allocate(NodeType type,
SchedulerNode node,
org.apache.hadoop.yarn.api.records.Priority priority,
org.apache.hadoop.yarn.api.records.ResourceRequest request,
org.apache.hadoop.yarn.api.records.Container container)
Resources have been allocated to this application by the resource
scheduler.
|
org.apache.hadoop.yarn.api.records.ResourceRequest |
cloneResourceRequest(org.apache.hadoop.yarn.api.records.ResourceRequest request) |
List<org.apache.hadoop.yarn.api.records.ResourceRequest> |
getAllResourceRequests() |
boolean |
getAndResetBlacklistChanged() |
org.apache.hadoop.yarn.api.records.ApplicationAttemptId |
getApplicationAttemptId() |
org.apache.hadoop.yarn.api.records.ApplicationId |
getApplicationId() |
String |
getApplicationLabel() |
Set<String> |
getBlackList() |
long |
getNewContainerId() |
Collection<org.apache.hadoop.yarn.api.records.Priority> |
getPriorities() |
String |
getQueueName() |
org.apache.hadoop.yarn.api.records.Resource |
getResource(org.apache.hadoop.yarn.api.records.Priority priority) |
org.apache.hadoop.yarn.api.records.ResourceRequest |
getResourceRequest(org.apache.hadoop.yarn.api.records.Priority priority,
String resourceName) |
Map<String,org.apache.hadoop.yarn.api.records.ResourceRequest> |
getResourceRequests(org.apache.hadoop.yarn.api.records.Priority priority) |
String |
getUser() |
boolean |
isBlacklisted(SchedulerNode node,
org.apache.commons.logging.Log myLog) |
boolean |
isBlacklisted(String resourceName) |
boolean |
isPending() |
void |
move(Queue newQueue) |
void |
recoverContainer(RMContainer rmContainer) |
void |
setApplicationLabel(String applicationLabel) |
void |
setQueue(Queue queue) |
void |
stop(RMAppAttemptState rmAppAttemptFinalState) |
void |
transferStateFromPreviousAppSchedulingInfo(AppSchedulingInfo appInfo) |
void |
updateBlacklist(List<String> blacklistAdditions,
List<String> blacklistRemovals)
The ApplicationMaster is updating the blacklist
|
void |
updateResourceRequests(List<org.apache.hadoop.yarn.api.records.ResourceRequest> requests,
boolean recoverPreemptedRequest)
The ApplicationMaster is updating resource requirements for the
application, by asking for more resources and releasing resources acquired
by the application.
|
public AppSchedulingInfo(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId, String user, Queue queue, ActiveUsersManager activeUsersManager, long epoch)
public void setApplicationLabel(String applicationLabel)
public String getApplicationLabel()
public org.apache.hadoop.yarn.api.records.ApplicationId getApplicationId()
public org.apache.hadoop.yarn.api.records.ApplicationAttemptId getApplicationAttemptId()
public String getQueueName()
public String getUser()
public boolean isPending()
public long getNewContainerId()
public void updateResourceRequests(List<org.apache.hadoop.yarn.api.records.ResourceRequest> requests, boolean recoverPreemptedRequest)
requests
- resources to be acquiredrecoverPreemptedRequest
- recover Resource Request on preemptionpublic void updateBlacklist(List<String> blacklistAdditions, List<String> blacklistRemovals)
blacklistAdditions
- resources to be added to the blacklistblacklistRemovals
- resources to be removed from the blacklistpublic boolean getAndResetBlacklistChanged()
public Collection<org.apache.hadoop.yarn.api.records.Priority> getPriorities()
public Map<String,org.apache.hadoop.yarn.api.records.ResourceRequest> getResourceRequests(org.apache.hadoop.yarn.api.records.Priority priority)
public List<org.apache.hadoop.yarn.api.records.ResourceRequest> getAllResourceRequests()
public org.apache.hadoop.yarn.api.records.ResourceRequest getResourceRequest(org.apache.hadoop.yarn.api.records.Priority priority, String resourceName)
public org.apache.hadoop.yarn.api.records.Resource getResource(org.apache.hadoop.yarn.api.records.Priority priority)
public boolean isBlacklisted(SchedulerNode node, org.apache.commons.logging.Log myLog)
public boolean isBlacklisted(String resourceName)
public List<org.apache.hadoop.yarn.api.records.ResourceRequest> allocate(NodeType type, SchedulerNode node, org.apache.hadoop.yarn.api.records.Priority priority, org.apache.hadoop.yarn.api.records.ResourceRequest request, org.apache.hadoop.yarn.api.records.Container container)
type
- the type of the nodenode
- the nodeinfo of the nodepriority
- the priority of the request.request
- the requestcontainer
- the containers allocated.public void move(Queue newQueue)
public void stop(RMAppAttemptState rmAppAttemptFinalState)
public void setQueue(Queue queue)
public void transferStateFromPreviousAppSchedulingInfo(AppSchedulingInfo appInfo)
public void recoverContainer(RMContainer rmContainer)
public org.apache.hadoop.yarn.api.records.ResourceRequest cloneResourceRequest(org.apache.hadoop.yarn.api.records.ResourceRequest request)
Copyright © 2017 Apache Software Foundation. All Rights Reserved.