|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.hadoop.yarn.server.resourcemanager.scheduler.AppSchedulingInfo
@InterfaceAudience.Private @InterfaceStability.Unstable public class AppSchedulingInfo
This class keeps track of all the consumption of an application. This also keeps track of current running/completed containers for the application.
Constructor Summary | |
---|---|
AppSchedulingInfo(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId,
String user,
Queue queue,
ActiveUsersManager activeUsersManager)
|
Method Summary | |
---|---|
void |
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. |
List<org.apache.hadoop.yarn.api.records.ResourceRequest> |
getAllResourceRequests()
|
org.apache.hadoop.yarn.api.records.ApplicationAttemptId |
getApplicationAttemptId()
|
org.apache.hadoop.yarn.api.records.ApplicationId |
getApplicationId()
|
int |
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(String resourceName)
|
boolean |
isPending()
|
void |
setQueue(Queue queue)
|
void |
stop(RMAppAttemptState rmAppAttemptFinalState)
|
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)
The ApplicationMaster is updating resource requirements for the application, by asking for more resources and releasing resources acquired by the application. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public AppSchedulingInfo(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId, String user, Queue queue, ActiveUsersManager activeUsersManager)
Method Detail |
---|
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 int getNewContainerId()
public void updateResourceRequests(List<org.apache.hadoop.yarn.api.records.ResourceRequest> requests)
requests
- resources to be acquiredpublic void updateBlacklist(List<String> blacklistAdditions, List<String> blacklistRemovals)
blacklistAdditions
- resources to be added to the blacklistblacklistRemovals
- resources to be removed from the blacklistpublic 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(String resourceName)
public void 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 stop(RMAppAttemptState rmAppAttemptFinalState)
public void setQueue(Queue queue)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |