Uses of Interface
org.apache.hadoop.yarn.server.resourcemanager.scheduler.Queue
Packages that use Queue
Package
Description
-
Uses of Queue in org.apache.hadoop.yarn.server.resourcemanager.reservation
Methods in org.apache.hadoop.yarn.server.resourcemanager.reservation that return QueueModifier and TypeMethodDescriptionprotected abstract QueueAbstractSchedulerPlanFollower.getPlanQueue(String planQueueName) Get queue associated with reservable queue named.protected QueueCapacitySchedulerPlanFollower.getPlanQueue(String planQueueName) protected QueueFairSchedulerPlanFollower.getPlanQueue(String planQueueName) Methods in org.apache.hadoop.yarn.server.resourcemanager.reservation that return types with arguments of type QueueModifier and TypeMethodDescriptionAbstractSchedulerPlanFollower.getChildReservationQueues(Queue planQueue) Get a list of reservation queues for this planQueue.CapacitySchedulerPlanFollower.getChildReservationQueues(Queue queue) FairSchedulerPlanFollower.getChildReservationQueues(Queue queue) Methods in org.apache.hadoop.yarn.server.resourcemanager.reservation with parameters of type QueueModifier and TypeMethodDescriptionprotected abstract voidAbstractSchedulerPlanFollower.addReservationQueue(String planQueueName, Queue queue, String currResId) Add a new reservation queue for reservation currResId for this planQueue.protected voidCapacitySchedulerPlanFollower.addReservationQueue(String planQueueName, Queue queue, String currResId) protected voidFairSchedulerPlanFollower.addReservationQueue(String planQueueName, Queue queue, String currResId) protected abstract voidAbstractSchedulerPlanFollower.createDefaultReservationQueue(String planQueueName, Queue queue, String defReservationQueue) Creates the default reservation queue for use when no reservation is used for applications submitted to this planQueue.protected voidCapacitySchedulerPlanFollower.createDefaultReservationQueue(String planQueueName, Queue queue, String defReservationId) protected voidFairSchedulerPlanFollower.createDefaultReservationQueue(String planQueueName, Queue queue, String defReservationId) AbstractSchedulerPlanFollower.getChildReservationQueues(Queue planQueue) Get a list of reservation queues for this planQueue.CapacitySchedulerPlanFollower.getChildReservationQueues(Queue queue) FairSchedulerPlanFollower.getChildReservationQueues(Queue queue) protected abstract org.apache.hadoop.yarn.api.records.ResourceAbstractSchedulerPlanFollower.getPlanResources(Plan plan, Queue queue, org.apache.hadoop.yarn.api.records.Resource clusterResources) Get plan resources for this planQueue.protected org.apache.hadoop.yarn.api.records.ResourceCapacitySchedulerPlanFollower.getPlanResources(Plan plan, Queue queue, org.apache.hadoop.yarn.api.records.Resource clusterResources) protected org.apache.hadoop.yarn.api.records.ResourceFairSchedulerPlanFollower.getPlanResources(Plan plan, Queue queue, org.apache.hadoop.yarn.api.records.Resource clusterResources) -
Uses of Queue in org.apache.hadoop.yarn.server.resourcemanager.scheduler
Subinterfaces of Queue in org.apache.hadoop.yarn.server.resourcemanager.schedulerModifier and TypeInterfaceDescriptioninterfaceSchedulerQueue<T extends SchedulerQueue>Represents a queue in Scheduler.Fields in org.apache.hadoop.yarn.server.resourcemanager.scheduler declared as QueueMethods in org.apache.hadoop.yarn.server.resourcemanager.scheduler that return QueueModifier and TypeMethodDescriptionQueueMetrics.getParentQueue()Get queue object based on queue name.SchedulerApplication.getQueue()SchedulerApplicationAttempt.getQueue()Methods in org.apache.hadoop.yarn.server.resourcemanager.scheduler with parameters of type QueueModifier and TypeMethodDescriptionvoidvoidAdd to the scheduler a new Queue.static QueueMetricsQueueMetrics.forQueue(String queueName, Queue parent, boolean enableUserMetrics, org.apache.hadoop.conf.Configuration conf) static QueueMetricsQueueMetrics.forQueue(org.apache.hadoop.metrics2.MetricsSystem ms, String queueName, Queue parent, boolean enableUserMetrics, org.apache.hadoop.conf.Configuration conf) voidvoidvoidQueueMetrics.setParentQueue(Queue parentQueue) voidvoidstatic voidAppSchedulingInfo.updateMetrics(org.apache.hadoop.yarn.api.records.ApplicationId applicationId, NodeType type, SchedulerNode node, RMContainer containerAllocated, String user, Queue queue) Constructors in org.apache.hadoop.yarn.server.resourcemanager.scheduler with parameters of type QueueModifierConstructorDescriptionAppSchedulingInfo(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId, String user, Queue queue, AbstractUsersManager abstractUsersManager, long epoch, ResourceUsage appResourceUsage, Map<String, String> applicationSchedulingEnvs, RMContext rmContext, boolean unmanagedAM) protectedPartitionQueueMetrics(org.apache.hadoop.metrics2.MetricsSystem ms, String queueName, Queue parent, boolean enableUserMetrics, org.apache.hadoop.conf.Configuration conf, String partition) QueueMetrics(org.apache.hadoop.metrics2.MetricsSystem ms, String queueName, Queue parent, boolean enableUserMetrics, org.apache.hadoop.conf.Configuration conf) SchedulerApplication(Queue queue, String user, boolean unmanagedAM) SchedulerApplication(Queue queue, String user, org.apache.hadoop.yarn.api.records.Priority priority, boolean unmanagedAM) SchedulerApplicationAttempt(org.apache.hadoop.yarn.api.records.ApplicationAttemptId applicationAttemptId, String user, Queue queue, AbstractUsersManager abstractUsersManager, RMContext rmContext) -
Uses of Queue in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity
Subinterfaces of Queue in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacityModifier and TypeInterfaceDescriptioninterfaceCSQueuerepresents a node in the tree of hierarchical queues in theCapacityScheduler.Classes in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity that implement QueueModifier and TypeClassDescriptionclassAbstract class for dynamic auto created queues managed by an implementation of AbstractManagedParentQueueclassProvides implementation ofCSQueuemethods common for every queue class in Capacity Scheduler.classclassA container class for automatically created child leaf queues.classclassLeaf queues which are auto created by an underlying implementation of AbstractManagedParentQueue.classclassAuto Creation enabled Parent queue.classclassThis represents a dynamic queue managed by theReservationSystem.classThis represents a dynamicLeafQueuemanaged by theReservationSystemMethods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity with parameters of type QueueModifier and TypeMethodDescriptionvoidCapacitySchedulerQueueManager.addLegacyDynamicQueue(Queue queue) Adds anAutoCreatedLeafQueueto the manager collection and extends the children collection of its parent.voidstatic CSQueueMetricsCSQueueMetrics.forQueue(String queueName, Queue parent, boolean enableUserMetrics, org.apache.hadoop.conf.Configuration conf) -
Uses of Queue in org.apache.hadoop.yarn.server.resourcemanager.scheduler.common.fica
Constructors in org.apache.hadoop.yarn.server.resourcemanager.scheduler.common.fica with parameters of type QueueModifierConstructorDescriptionFiCaSchedulerApp(org.apache.hadoop.yarn.api.records.ApplicationAttemptId applicationAttemptId, String user, Queue queue, AbstractUsersManager abstractUsersManager, RMContext rmContext) FiCaSchedulerApp(org.apache.hadoop.yarn.api.records.ApplicationAttemptId applicationAttemptId, String user, Queue queue, AbstractUsersManager abstractUsersManager, RMContext rmContext, org.apache.hadoop.yarn.api.records.Priority appPriority, boolean isAttemptRecovering) FiCaSchedulerApp(org.apache.hadoop.yarn.api.records.ApplicationAttemptId applicationAttemptId, String user, Queue queue, AbstractUsersManager abstractUsersManager, RMContext rmContext, org.apache.hadoop.yarn.api.records.Priority appPriority, boolean isAttemptRecovering, ActivitiesManager activitiesManager) -
Uses of Queue in org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair
Classes in org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair that implement QueueMethods in org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair with parameters of type QueueModifier and TypeMethodDescriptionstatic FSQueueMetricsFSQueueMetrics.forQueue(String queueName, Queue parent, boolean enableUserMetrics, org.apache.hadoop.conf.Configuration conf) static FSQueueMetricsFSQueueMetrics.forQueue(org.apache.hadoop.metrics2.MetricsSystem ms, String queueName, Queue parent, boolean enableUserMetrics, org.apache.hadoop.conf.Configuration conf) Get the FS queue metric for the given queue.