org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity

Class PlanQueue

java.lang.Object

org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.AbstractCSQueue

org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.ParentQueue

org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.PlanQueue

All Implemented Interfaces:

CSQueue, Queue

public class PlanQueue
extends ParentQueue

This represents a dynamic queue managed by the ReservationSystem. From the user perspective this is equivalent to a LeafQueue that respect reservations, but functionality wise is a sub-class of ParentQueue

Field Summary

Fields

Modifier and Type	Field and Description
protected CapacitySchedulerContext	schedulerContext

Fields inherited from class org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.ParentQueue

childQueues

Fields inherited from class org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.AbstractCSQueue

authorizer, csContext, queueEntity

Constructor Summary

Constructors

Constructor and Description
PlanQueue(CapacitySchedulerContext cs, String queueName, CSQueue parent, CSQueue old)

Method Summary

Methods

Modifier and Type	Method and Description
int	getMaxApplicationsForReservations() Number of maximum applications for each of the reservations in this Plan.
int	getMaxApplicationsPerUserForReservation() Number of maximum applications per user for each of the reservations in this Plan.
float	getUserLimitFactor() User limit factor value for each of the reservations in this Plan.
int	getUserLimitForReservation() User limit value for each of the reservations in this Plan.
void	reinitialize(CSQueue newlyParsedQueue, org.apache.hadoop.yarn.api.records.Resource clusterResource) Reinitialize the queue.
boolean	showReservationsAsQueues() Determine whether to hide/show the ReservationQueues
protected float	sumOfChildCapacities()

Methods inherited from class org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.ParentQueue

assignContainers, attachContainer, collectSchedulerApplications, completedContainer, decreaseContainer, detachContainer, finishApplication, finishApplicationAttempt, getActiveUsersManager, getChildQueues, getNumApplications, getOffSwitchPerHeartbeatLimit, getQueueInfo, getQueueUserAclInfo, hasChildQueues, recoverContainer, submitApplication, submitApplicationAttempt, toString, unreserveIncreasedContainer, updateClusterResource

Methods inherited from class org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.AbstractCSQueue

accessibleToPartition, decPendingResource, decReservedResource, decUsedResource, getAbsoluteCapacity, getAbsoluteMaximumCapacity, getAbsoluteUsedCapacity, getAccessibleNodeLabels, getACLs, getCapacity, getDefaultApplicationPriority, getDefaultNodeLabelExpression, getKillableContainers, getMaximumAllocation, getMaximumCapacity, getMetrics, getMinimumAllocation, getNodeLabelsForQueue, getNumContainers, getParent, getPreemptionDisabled, getPrivilegedEntity, getQueueCapacities, getQueueInfo, getQueueName, getQueuePath, getQueueResourceUsage, getQueueStatistics, getReservationContinueLooking, getState, getTotalKillableResource, getUsedCapacity, getUsedResources, getUserWeights, hasAccess, incPendingResource, incReservedResource, incUsedResource, releaseResource, setAbsoluteUsedCapacity, setParent, setupConfigurableCapacities, setUsedCapacity

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

schedulerContext

protected CapacitySchedulerContext schedulerContext

Constructor Detail

PlanQueue

public PlanQueue(CapacitySchedulerContext cs,
         String queueName,
         CSQueue parent,
         CSQueue old)
          throws IOException

Throws:

IOException

Method Detail

reinitialize

public void reinitialize(CSQueue newlyParsedQueue,
                org.apache.hadoop.yarn.api.records.Resource clusterResource)
                  throws IOException

Description copied from interface: CSQueue

Reinitialize the queue.

Specified by:

reinitialize in interface CSQueue

Overrides:

reinitialize in class ParentQueue

Parameters:

newlyParsedQueue - new queue to re-initalize from

clusterResource - resources in the cluster

Throws:

IOException

sumOfChildCapacities

protected float sumOfChildCapacities()

getMaxApplicationsForReservations

public int getMaxApplicationsForReservations()

Number of maximum applications for each of the reservations in this Plan.

Returns:

maxAppsForreservation

getMaxApplicationsPerUserForReservation

public int getMaxApplicationsPerUserForReservation()

Number of maximum applications per user for each of the reservations in this Plan.

Returns:

maxAppsPerUserForreservation

getUserLimitForReservation

public int getUserLimitForReservation()

User limit value for each of the reservations in this Plan.

Returns:

userLimit

getUserLimitFactor

public float getUserLimitFactor()

User limit factor value for each of the reservations in this Plan.

Returns:

userLimitFactor

showReservationsAsQueues

public boolean showReservationsAsQueues()

Determine whether to hide/show the ReservationQueues