@InterfaceAudience.Private @InterfaceStability.Unstable public class AppSchedulingInfo extends Object
Constructor and Description |
---|
AppSchedulingInfo(ApplicationAttemptId appAttemptId,
String user,
Queue queue,
ActiveUsersManager activeUsersManager) |
Modifier and Type | Method and Description |
---|---|
void |
allocate(NodeType type,
SchedulerNode node,
Priority priority,
ResourceRequest request,
Container container)
Resources have been allocated to this application by the resource
scheduler.
|
List<ResourceRequest> |
getAllResourceRequests() |
ApplicationAttemptId |
getApplicationAttemptId() |
ApplicationId |
getApplicationId() |
int |
getNewContainerId() |
Collection<Priority> |
getPriorities() |
String |
getQueueName() |
Resource |
getResource(Priority priority) |
ResourceRequest |
getResourceRequest(Priority priority,
String resourceName) |
Map<String,ResourceRequest> |
getResourceRequests(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<ResourceRequest> requests)
The ApplicationMaster is updating resource requirements for the
application, by asking for more resources and releasing resources acquired
by the application.
|
public AppSchedulingInfo(ApplicationAttemptId appAttemptId, String user, Queue queue, ActiveUsersManager activeUsersManager)
public ApplicationId getApplicationId()
public ApplicationAttemptId getApplicationAttemptId()
public String getQueueName()
public String getUser()
public boolean isPending()
public int getNewContainerId()
public void updateResourceRequests(List<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<Priority> getPriorities()
public Map<String,ResourceRequest> getResourceRequests(Priority priority)
public List<ResourceRequest> getAllResourceRequests()
public ResourceRequest getResourceRequest(Priority priority, String resourceName)
public boolean isBlacklisted(String resourceName)
public void allocate(NodeType type, SchedulerNode node, Priority priority, ResourceRequest request, 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)
Copyright © 2013 Apache Software Foundation. All rights reserved.