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

Class QueueStateManager<T extends SchedulerQueue,E extends ReservationSchedulerConfiguration>

java.lang.Object

org.apache.hadoop.yarn.server.resourcemanager.scheduler.QueueStateManager<T,E>

@Private
@Unstable
public class QueueStateManager<T extends SchedulerQueue,E extends ReservationSchedulerConfiguration>
extends Object

QueueStateManager which can be used by Scheduler to manage the queue state.

Constructor Summary

Constructors

Constructor	Description
QueueStateManager()

Method Summary

Modifier and Type	Method	Description
void	activateQueue(String queueName)	Active the queue.
boolean	canDelete(String queueName)	Whether this queue can be deleted.
void	initialize(SchedulerQueueManager<T,E> newQueueManager)
void	stopQueue(String queueName)	Stop the queue.

Methods inherited from class java.lang.Object

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

Constructor Details

QueueStateManager

public QueueStateManager()

Method Details

initialize

public void initialize(SchedulerQueueManager<T,E> newQueueManager)

stopQueue

public void stopQueue(String queueName)
               throws org.apache.hadoop.yarn.exceptions.YarnException

Stop the queue.

Parameters:

queueName - the queue name

Throws:

org.apache.hadoop.yarn.exceptions.YarnException - if the queue does not exist

activateQueue

public void activateQueue(String queueName)
                   throws org.apache.hadoop.yarn.exceptions.YarnException

Active the queue.

Parameters:

queueName - the queue name

Throws:

org.apache.hadoop.yarn.exceptions.YarnException - if the queue does not exist or the queue can not be activated.

canDelete

public boolean canDelete(String queueName)

Whether this queue can be deleted.

Parameters:

queueName - the queue name

Returns:

true if the queue can be deleted