public class PlanQueue extends ParentQueue
ReservationSystem
.
From the user perspective this is equivalent to a LeafQueue that respect
reservations, but functionality wise is a sub-class of ParentQueueModifier and Type | Field and Description |
---|---|
protected CapacitySchedulerContext |
schedulerContext |
childQueues
authorizer, csContext, queueEntity
Constructor and Description |
---|
PlanQueue(CapacitySchedulerContext cs,
String queueName,
CSQueue parent,
CSQueue old) |
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() |
assignContainers, attachContainer, collectSchedulerApplications, completedContainer, decreaseContainer, detachContainer, finishApplication, finishApplicationAttempt, getActiveUsersManager, getChildQueues, getNumApplications, getOffSwitchPerHeartbeatLimit, getQueueInfo, getQueueUserAclInfo, hasChildQueues, recoverContainer, submitApplication, submitApplicationAttempt, toString, unreserveIncreasedContainer, updateClusterResource
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
protected CapacitySchedulerContext schedulerContext
public PlanQueue(CapacitySchedulerContext cs, String queueName, CSQueue parent, CSQueue old) throws IOException
IOException
public void reinitialize(CSQueue newlyParsedQueue, org.apache.hadoop.yarn.api.records.Resource clusterResource) throws IOException
CSQueue
reinitialize
in interface CSQueue
reinitialize
in class ParentQueue
newlyParsedQueue
- new queue to re-initalize fromclusterResource
- resources in the clusterIOException
protected float sumOfChildCapacities()
public int getMaxApplicationsForReservations()
public int getMaxApplicationsPerUserForReservation()
public int getUserLimitForReservation()
public float getUserLimitFactor()
public boolean showReservationsAsQueues()
Copyright © 2017 Apache Software Foundation. All Rights Reserved.