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

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>

public class AutoCreatedLeafQueue
extends AbstractAutoCreatedLeafQueue

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

parent

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

maxApplications, maxApplicationsPerUser

Fields 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

Constructors

Constructor	Description
AutoCreatedLeafQueue(CapacitySchedulerQueueContext queueContext, String queueName, ManagedParentQueue parent)

Method Summary

Modifier and Type	Method	Description
void	mergeCapacities(QueueCapacities capacities, QueueResourceQuotas resourceQuotas)
protected void	parseAndSetDynamicTemplates()	Set properties specific to dynamic queues.
void	reinitialize(CSQueue newlyParsedQueue, org.apache.hadoop.yarn.api.records.Resource clusterResource)	Reinitialize the queue.
void	reinitializeFromTemplate(AutoCreatedLeafQueueConfig leafQueueTemplate)
void	validateConfigurations(AutoCreatedLeafQueueConfig template)

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

checkConfigTypeIsAbsoluteResource, getMaximumAbsoluteResource, getMinimumAbsoluteResource, setEntitlement, setEntitlement

Methods 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, validateSubmitApplication

Methods 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

Methods inherited from class java.lang.Object

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

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: CSQueue

Reinitialize the queue.

Specified by:

reinitialize in interface CSQueue

Overrides:

reinitialize in class AbstractLeafQueue

Parameters:

newlyParsedQueue - new queue to re-initalize from

clusterResource - resources in the cluster

Throws:

IOException - an I/O exception has occurred.

reinitializeFromTemplate

public void reinitializeFromTemplate(AutoCreatedLeafQueueConfig leafQueueTemplate)

mergeCapacities

public void mergeCapacities(QueueCapacities capacities,
 QueueResourceQuotas resourceQuotas)

validateConfigurations

public void validateConfigurations(AutoCreatedLeafQueueConfig template)
                            throws SchedulerDynamicEditException

Throws:

SchedulerDynamicEditException

parseAndSetDynamicTemplates

protected void parseAndSetDynamicTemplates()

Description copied from class: AbstractCSQueue

Set properties specific to dynamic queues.

Overrides:

parseAndSetDynamicTemplates in class AbstractLeafQueue