org.apache.hadoop.yarn.server.resourcemanager.scheduler.common.fica
Class FiCaSchedulerApp
java.lang.Object
org.apache.hadoop.yarn.server.resourcemanager.scheduler.SchedulerApplication
org.apache.hadoop.yarn.server.resourcemanager.scheduler.common.fica.FiCaSchedulerApp
@InterfaceAudience.Private
@InterfaceStability.Unstable
public class FiCaSchedulerApp
- extends SchedulerApplication
Represents an application attempt from the viewpoint of the FIFO or Capacity
scheduler.
Method Summary |
void |
addPreemptContainer(org.apache.hadoop.yarn.api.records.ContainerId cont)
|
RMContainer |
allocate(NodeType type,
FiCaSchedulerNode 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)
|
boolean |
containerCompleted(RMContainer rmContainer,
org.apache.hadoop.yarn.api.records.ContainerStatus containerStatus,
RMContainerEventType event)
|
Allocation |
getAllocation(org.apache.hadoop.yarn.util.resource.ResourceCalculator rc,
org.apache.hadoop.yarn.api.records.Resource clusterResource,
org.apache.hadoop.yarn.api.records.Resource minimumAllocation)
This method produces an Allocation that includes the current view
of the resources that will be allocated to and preempted from this
application. |
float |
getLocalityWaitFactor(org.apache.hadoop.yarn.api.records.Priority priority,
int clusterNodes)
|
org.apache.hadoop.yarn.api.records.Resource |
getTotalPendingRequests()
|
boolean |
unreserve(FiCaSchedulerNode node,
org.apache.hadoop.yarn.api.records.Priority priority)
|
Methods inherited from class org.apache.hadoop.yarn.server.resourcemanager.scheduler.SchedulerApplication |
addReReservation, addSchedulingOpportunity, containerLaunchedOnNode, getApplicationAttemptId, getApplicationId, getCurrentConsumption, getCurrentReservation, getHeadroom, getLiveContainers, getNewContainerId, getNumReservedContainers, getPriorities, getQueue, getQueueName, getReReservations, getReservedContainers, getResource, getResourceRequest, getResourceRequests, getRMContainer, getSchedulingOpportunities, getTotalRequiredResources, getUser, isBlacklisted, isPending, isReserved, isStopped, pullNewlyAllocatedContainers, reserve, resetReReservations, resetSchedulingOpportunities, resetSchedulingOpportunities, setHeadroom, showRequests, stop, subtractSchedulingOpportunity, updateBlacklist, updateResourceRequests |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
FiCaSchedulerApp
public FiCaSchedulerApp(org.apache.hadoop.yarn.api.records.ApplicationAttemptId applicationAttemptId,
String user,
Queue queue,
ActiveUsersManager activeUsersManager,
RMContext rmContext)
containerCompleted
public boolean containerCompleted(RMContainer rmContainer,
org.apache.hadoop.yarn.api.records.ContainerStatus containerStatus,
RMContainerEventType event)
allocate
public RMContainer allocate(NodeType type,
FiCaSchedulerNode 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)
unreserve
public boolean unreserve(FiCaSchedulerNode node,
org.apache.hadoop.yarn.api.records.Priority priority)
getLocalityWaitFactor
public float getLocalityWaitFactor(org.apache.hadoop.yarn.api.records.Priority priority,
int clusterNodes)
getTotalPendingRequests
public org.apache.hadoop.yarn.api.records.Resource getTotalPendingRequests()
addPreemptContainer
public void addPreemptContainer(org.apache.hadoop.yarn.api.records.ContainerId cont)
getAllocation
public Allocation getAllocation(org.apache.hadoop.yarn.util.resource.ResourceCalculator rc,
org.apache.hadoop.yarn.api.records.Resource clusterResource,
org.apache.hadoop.yarn.api.records.Resource minimumAllocation)
- This method produces an Allocation that includes the current view
of the resources that will be allocated to and preempted from this
application.
- Parameters:
rc
- clusterResource
- minimumAllocation
-
- Returns:
- an allocation
Copyright © 2014 Apache Software Foundation. All Rights Reserved.