@InterfaceAudience.Private @InterfaceStability.Unstable public class QueueManager extends Object
Modifier and Type | Field and Description |
---|---|
static org.apache.commons.logging.Log |
LOG |
static String |
ROOT_QUEUE |
Constructor and Description |
---|
QueueManager(FairScheduler scheduler) |
Modifier and Type | Method and Description |
---|---|
boolean |
exists(String name)
Return whether a queue exists already.
|
FSLeafQueue |
getLeafQueue(String name,
boolean create)
Get a leaf queue by name, creating it if the create param is true and is necessary.
|
Collection<FSLeafQueue> |
getLeafQueues()
Get a collection of all leaf queues
|
FSParentQueue |
getParentQueue(String name,
boolean create)
Get a parent queue by name, creating it if the create param is true and is necessary.
|
FSQueue |
getQueue(String name)
Gets a queue by name.
|
Collection<FSQueue> |
getQueues()
Get a collection of all queues
|
FSParentQueue |
getRootQueue() |
void |
initialize(org.apache.hadoop.conf.Configuration conf) |
protected boolean |
isEmpty(FSQueue queue)
Returns true if there are no applications, running or not, in the given
queue or any of its descendents.
|
boolean |
removeLeafQueue(String name)
Remove a leaf queue if empty
|
void |
updateAllocationConfiguration(AllocationConfiguration queueConf) |
public static final org.apache.commons.logging.Log LOG
public static final String ROOT_QUEUE
public QueueManager(FairScheduler scheduler)
public FSParentQueue getRootQueue()
public void initialize(org.apache.hadoop.conf.Configuration conf) throws IOException, SAXException, AllocationConfigurationException, ParserConfigurationException
public FSLeafQueue getLeafQueue(String name, boolean create)
public boolean removeLeafQueue(String name)
name
- name of the queuepublic FSParentQueue getParentQueue(String name, boolean create)
protected boolean isEmpty(FSQueue queue)
public boolean exists(String name)
public Collection<FSLeafQueue> getLeafQueues()
public Collection<FSQueue> getQueues()
public void updateAllocationConfiguration(AllocationConfiguration queueConf)
Copyright © 2015 Apache Software Foundation. All Rights Reserved.