|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.QueueManager
@InterfaceAudience.Private @InterfaceStability.Unstable public class QueueManager
Maintains a list of queues as well as scheduling parameters for each queue, such as guaranteed share allocations, from the fair scheduler config file.
Field Summary | |
---|---|
static long |
ALLOC_RELOAD_INTERVAL
Time to wait between checks of the allocation file |
static long |
ALLOC_RELOAD_WAIT
Time to wait after the allocation has been modified before reloading it (this is done to prevent loading a file that hasn't been fully written). |
static org.apache.commons.logging.Log |
LOG
|
static String |
ROOT_QUEUE
|
Constructor Summary | |
---|---|
QueueManager(FairScheduler scheduler)
|
Method Summary | |
---|---|
boolean |
exists(String name)
Return whether a queue exists already. |
long |
getFairSharePreemptionTimeout()
Get the fair share preemption, in milliseconds. |
FSLeafQueue |
getLeafQueue(String name,
boolean create)
Get a queue by name, creating it if the create param is true and is necessary. |
Collection<FSLeafQueue> |
getLeafQueues()
Get a collection of all leaf queues |
org.apache.hadoop.yarn.api.records.Resource |
getMaxResources(String queueName)
Get the maximum resource allocation for the given queue. |
org.apache.hadoop.yarn.api.records.Resource |
getMinResources(String queue)
Get the minimum resource allocation for the given queue. |
long |
getMinSharePreemptionTimeout(String queueName)
Get a queue's min share preemption timeout, in milliseconds. |
FSQueue |
getQueue(String name)
Gets a queue by name. |
org.apache.hadoop.security.authorize.AccessControlList |
getQueueAcl(String queue,
org.apache.hadoop.yarn.api.records.QueueACL operation)
Get the ACLs associated with this queue. |
int |
getQueueMaxApps(String queue)
|
Collection<FSQueue> |
getQueues()
Get a collection of all queues |
ResourceWeights |
getQueueWeight(String queue)
|
FSParentQueue |
getRootQueue()
|
int |
getUserMaxApps(String user)
|
void |
initialize()
|
void |
reloadAllocs()
Updates the allocation list from the allocation config file. |
void |
reloadAllocsIfNecessary()
Reload allocations file if it hasn't been loaded in a while |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final org.apache.commons.logging.Log LOG
public static final String ROOT_QUEUE
public static final long ALLOC_RELOAD_INTERVAL
public static final long ALLOC_RELOAD_WAIT
Constructor Detail |
---|
public QueueManager(FairScheduler scheduler)
Method Detail |
---|
public FSParentQueue getRootQueue()
public void initialize() throws IOException, SAXException, AllocationConfigurationException, ParserConfigurationException
IOException
SAXException
AllocationConfigurationException
ParserConfigurationException
public FSLeafQueue getLeafQueue(String name, boolean create)
public FSQueue getQueue(String name)
public boolean exists(String name)
public void reloadAllocsIfNecessary()
public void reloadAllocs() throws IOException, ParserConfigurationException, SAXException, AllocationConfigurationException
IOException
- if the config file cannot be read.
AllocationConfigurationException
- if allocations are invalid.
ParserConfigurationException
- if XML parser is misconfigured.
SAXException
- if config file is malformed.public org.apache.hadoop.yarn.api.records.Resource getMinResources(String queue)
public org.apache.hadoop.yarn.api.records.Resource getMaxResources(String queueName)
public Collection<FSLeafQueue> getLeafQueues()
public Collection<FSQueue> getQueues()
public int getUserMaxApps(String user)
public int getQueueMaxApps(String queue)
public ResourceWeights getQueueWeight(String queue)
public long getMinSharePreemptionTimeout(String queueName)
public long getFairSharePreemptionTimeout()
public org.apache.hadoop.security.authorize.AccessControlList getQueueAcl(String queue, org.apache.hadoop.yarn.api.records.QueueACL operation)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |