Uses of Class
org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity.TempQueuePerPartition
Packages that use TempQueuePerPartition
-
Uses of TempQueuePerPartition in org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity
Methods in org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity that return TempQueuePerPartitionModifier and TypeMethodDescriptionCapacitySchedulerPreemptionContext.getQueueByPartition(String queueName, String partition) ProportionalCapacityPreemptionPolicy.getQueueByPartition(String queueName, String partition) Get queue partition by given queueName and partitionNameMethods in org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity that return types with arguments of type TempQueuePerPartitionModifier and TypeMethodDescriptionTempQueuePerPartition.getChildren()CapacitySchedulerPreemptionContext.getQueuePartitions(String queueName) ProportionalCapacityPreemptionPolicy.getQueuePartitions(String queueName) Get all queue partitions by given queueNameMethods in org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity with parameters of type TempQueuePerPartitionModifier and TypeMethodDescriptionvoidTempQueuePerPartition.addChild(TempQueuePerPartition q) When adding a child we also aggregate its pending resource needs.voidFifoIntraQueuePreemptionPlugin.computeAppsIdealAllocation(org.apache.hadoop.yarn.api.records.Resource clusterResource, TempQueuePerPartition tq, Map<org.apache.hadoop.yarn.api.records.ApplicationAttemptId, Set<RMContainer>> selectedCandidates, org.apache.hadoop.yarn.api.records.Resource totalPreemptedResourceAllowed, org.apache.hadoop.yarn.api.records.Resource queueReassignableResource, float maxAllowablePreemptLimit) protected voidAbstractPreemptableResourceCalculator.initIdealAssignment(org.apache.hadoop.yarn.api.records.Resource totGuarant, TempQueuePerPartition q, org.apache.hadoop.yarn.api.records.Resource initIdealAssigned) This method is visible to allow sub-classes to override the initialization behavior.protected voidPreemptableResourceCalculator.recursivelyComputeIdealAssignment(TempQueuePerPartition root, org.apache.hadoop.yarn.api.records.Resource totalPreemptionAllowed) This method recursively computes the ideal assignment of resources to each level of the hierarchy.Method parameters in org.apache.hadoop.yarn.server.resourcemanager.monitor.capacity with type arguments of type TempQueuePerPartitionModifier and TypeMethodDescriptionprotected voidAbstractPreemptableResourceCalculator.computeFixpointAllocation(org.apache.hadoop.yarn.api.records.Resource totGuarant, Collection<TempQueuePerPartition> qAlloc, org.apache.hadoop.yarn.api.records.Resource unassigned, boolean ignoreGuarantee) Given a set of queues compute the fix-point distribution of unassigned resources among them.protected voidPreemptableResourceCalculator.computeIdealResourceDistribution(org.apache.hadoop.yarn.util.resource.ResourceCalculator rc, List<TempQueuePerPartition> queues, org.apache.hadoop.yarn.api.records.Resource totalPreemptionAllowed, org.apache.hadoop.yarn.api.records.Resource tot_guarant) This method computes (for a single level in the tree, passed as aList<TempQueue>) the ideal assignment of resources.