Class AutoCreatedLeafQueue
java.lang.Object
org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.AbstractCSQueue
org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.AbstractLeafQueue
org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.AbstractAutoCreatedLeafQueue
org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.AutoCreatedLeafQueue
- All Implemented Interfaces:
CSQueue,Queue,SchedulerQueue<CSQueue>
Leaf queues which are auto created by an underlying implementation of
AbstractManagedParentQueue. Eg: PlanQueue for reservations or
ManagedParentQueue for auto created dynamic queues
-
Nested Class Summary
Nested classes/interfaces inherited from class org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.AbstractCSQueue
AbstractCSQueue.CapacityConfigType -
Field Summary
Fields inherited from class org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.AbstractAutoCreatedLeafQueue
parentFields inherited from class org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.AbstractLeafQueue
maxApplications, maxApplicationsPerUserFields inherited from class org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.AbstractCSQueue
activitiesManager, authorizer, capacityConfigType, configuredCapacityVectors, configuredMaxCapacityVectors, queueAllocationSettings, queueContext, queueEntity, queueNodeLabelsSettings, queuePath, readLock, writeLock -
Constructor Summary
ConstructorsConstructorDescriptionAutoCreatedLeafQueue(CapacitySchedulerQueueContext queueContext, String queueName, ManagedParentQueue parent) -
Method Summary
Modifier and TypeMethodDescriptionvoidmergeCapacities(QueueCapacities capacities, QueueResourceQuotas resourceQuotas) protected voidSet properties specific to dynamic queues.voidreinitialize(CSQueue newlyParsedQueue, org.apache.hadoop.yarn.api.records.Resource clusterResource) Reinitialize the queue.voidreinitializeFromTemplate(AutoCreatedLeafQueueConfig leafQueueTemplate) voidMethods inherited from class org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.AbstractAutoCreatedLeafQueue
checkConfigTypeIsAbsoluteResource, getMaximumAbsoluteResource, getMinimumAbsoluteResource, setEntitlement, setEntitlementMethods inherited from class org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.AbstractLeafQueue
accept, activateApplications, apply, assignContainers, attachContainer, calculateAndGetAMResourceLimit, calculateAndGetAMResourceLimitPerPartition, canAssignToUser, collectSchedulerApplications, completedContainer, decAMUsedResource, decUsedResource, detachContainer, finishApplication, finishApplicationAttempt, getAbstractUsersManager, getAllApplications, getAllUsers, getAMResourceLimit, getAMResourceLimitPerPartition, getApplications, getChildQueues, getChildQueuesByTryLock, getDefaultApplicationPriority, getExtendedCapacityOrWeightString, getHeadroom, getHeadroom, getIgnoreExclusivityRMContainers, getMaxAMResourcePerQueuePercent, getMaxApplications, getMaxApplicationsPerUser, getMinimumAllocationFactor, getNodeLocalityDelay, getNumActiveApplications, getNumActiveApplications, getNumApplications, getNumPendingApplications, getNumPendingApplications, getOrCreateUser, getOrderingPolicy, getPendingApplications, getPendingAppsOrderingPolicy, getPriorityACLs, getQueueInfo, getQueueUserAclInfo, getRackLocalityAdditionalDelay, getRackLocalityFullReset, getResourceLimitForActiveUsers, getResourceLimitForAllUsers, getTotalPendingResourcesConsideringUserLimit, getUser, getUserAMResourceLimit, getUserAMResourceLimitPerPartition, getUserLimit, getUserLimitFactor, getUsersManager, incAMUsedResource, incUsedResource, isEligibleForAutoDeletion, recalculateQueueUsageRatio, recoverContainer, refreshAfterResourceCalculation, setAbsoluteCapacity, setAbsoluteCapacity, setCapacity, setCapacity, setDynamicQueueACLProperties, setMaxAMResourcePerQueuePercent, setMaxApplications, setMaxApplicationsPerUser, setupQueueConfigs, stopQueue, submitApplication, submitApplicationAttempt, submitApplicationAttempt, toString, updateApplicationPriority, updateClusterResource, updateClusterResourceLegacyMode, validateSubmitApplicationMethods inherited from class org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.AbstractCSQueue
activateQueue, appFinished, assignContainers, decPendingResource, decReservedResource, getAbsoluteCapacity, getAbsoluteMaximumCapacity, getAbsoluteUsedCapacity, getAccessibleNodeLabels, getACLs, getCapacity, getCapacityConfigType, getCapacityOrWeightString, getConfiguredCapacityVector, getConfiguredMaxCapacityVector, getConfiguredNodeLabels, getDefaultApplicationLifetime, getDefaultAppLifetimeWasSpecifiedInConfig, getDefaultNodeLabelExpression, getEffectiveCapacity, getEffectiveCapacityDown, getEffectiveMaxCapacity, getEffectiveMaxCapacityDown, getIntraQueuePreemptionDisabled, getIntraQueuePreemptionDisabledInHierarchy, getKillableContainers, getMaximumAllocation, getMaximumApplicationLifetime, getMaximumCapacity, getMaxParallelApps, getMetrics, getMinimumAllocation, getMultiNodeSortingPolicyClassName, getNodeLabelsForQueue, getNumContainers, getParent, getPreemptionDisabled, getPriority, getPrivilegedEntity, getQueueCapacities, getQueueContext, getQueueInfo, getQueueName, getQueuePath, getQueuePathObject, getQueueResourceQuotas, getQueueResourceUsage, getQueueShortName, getReadLock, getState, getTotalKillableResource, getUsedCapacity, getUsedResources, getUserWeights, getWriteLock, hasAccess, incPendingResource, incReservedResource, isDynamicQueue, isInactiveDynamicQueue, isReservationsContinueLooking, overrideCapacityVectorsForSpecialQueues, recoverDrainingState, releaseResource, setConfiguredMaxCapacityVector, setConfiguredMinCapacityVector, setDynamicQueue, setMaxParallelApps, setMultiNodeSortingPolicyClassName, setParent, setupConfigurableCapacities, updateAbsoluteCapacities, updateCapacityConfigType, updateConfigurableResourceLimits, updateQueueState
-
Constructor Details
-
AutoCreatedLeafQueue
public AutoCreatedLeafQueue(CapacitySchedulerQueueContext queueContext, String queueName, ManagedParentQueue parent) throws IOException - Throws:
IOException
-
-
Method Details
-
reinitialize
public void reinitialize(CSQueue newlyParsedQueue, org.apache.hadoop.yarn.api.records.Resource clusterResource) throws IOException Description copied from interface:CSQueueReinitialize the queue.- Specified by:
reinitializein interfaceCSQueue- Overrides:
reinitializein classAbstractLeafQueue- Parameters:
newlyParsedQueue- new queue to re-initalize fromclusterResource- resources in the cluster- Throws:
IOException- an I/O exception has occurred.
-
reinitializeFromTemplate
-
mergeCapacities
-
validateConfigurations
public void validateConfigurations(AutoCreatedLeafQueueConfig template) throws SchedulerDynamicEditException - Throws:
SchedulerDynamicEditException
-
parseAndSetDynamicTemplates
protected void parseAndSetDynamicTemplates()Description copied from class:AbstractCSQueueSet properties specific to dynamic queues.- Overrides:
parseAndSetDynamicTemplatesin classAbstractLeafQueue
-