org.apache.hadoop.yarn.server.resourcemanager.scheduler.common.fica
Class FiCaSchedulerApp

java.lang.Object
  extended by org.apache.hadoop.yarn.server.resourcemanager.scheduler.SchedulerApplication
      extended by 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.


Field Summary
 
Fields inherited from class org.apache.hadoop.yarn.server.resourcemanager.scheduler.SchedulerApplication
appSchedulingInfo, currentConsumption, currentReservation, isStopped, lastScheduledContainer, liveContainers, newlyAllocatedContainers, queue, reservedContainers, rmContext
 
Constructor Summary
FiCaSchedulerApp(org.apache.hadoop.yarn.api.records.ApplicationAttemptId applicationAttemptId, String user, Queue queue, ActiveUsersManager activeUsersManager, RMContext rmContext)
           
 
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
 

Constructor Detail

FiCaSchedulerApp

public FiCaSchedulerApp(org.apache.hadoop.yarn.api.records.ApplicationAttemptId applicationAttemptId,
                        String user,
                        Queue queue,
                        ActiveUsersManager activeUsersManager,
                        RMContext rmContext)
Method Detail

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.