@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.
|
FSLeafQueue |
getLeafQueue(String name,
boolean create,
boolean recomputeSteadyShares) |
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.
|
FSParentQueue |
getParentQueue(String name,
boolean create,
boolean recomputeSteadyShares) |
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 FSLeafQueue getLeafQueue(String name, boolean create, boolean recomputeSteadyShares)
public boolean removeLeafQueue(String name)
name
- name of the queuepublic FSParentQueue getParentQueue(String name, boolean create)
public FSParentQueue getParentQueue(String name, boolean create, boolean recomputeSteadyShares)
protected boolean isEmpty(FSQueue queue)
public boolean exists(String name)
public Collection<FSLeafQueue> getLeafQueues()
public Collection<FSQueue> getQueues()
public void updateAllocationConfiguration(AllocationConfiguration queueConf)
Copyright © 2017 Apache Software Foundation. All Rights Reserved.