public static class QueuePlacementRule.Default extends QueuePlacementRule
QueuePlacementRule.Default, QueuePlacementRule.NestedUserQueue, QueuePlacementRule.PrimaryGroup, QueuePlacementRule.Reject, QueuePlacementRule.SecondaryGroupExistingQueue, QueuePlacementRule.Specified, QueuePlacementRule.User
create, LOG
Constructor and Description |
---|
QueuePlacementRule.Default() |
Modifier and Type | Method and Description |
---|---|
protected String |
getQueueForApp(String requestedQueue,
String user,
org.apache.hadoop.security.Groups groups,
Map<FSQueueType,Set<String>> configuredQueues)
Applies this rule to an app with the given requested queue and user/group
information.
|
QueuePlacementRule |
initialize(boolean create,
Map<String,String> args)
Initializes the rule with any arguments.
|
void |
initializeFromXml(Element el) |
boolean |
isTerminal()
Returns true if this rule never tells the policy to continue.
|
assignAppToQueue, cleanName
public QueuePlacementRule initialize(boolean create, Map<String,String> args)
QueuePlacementRule
initialize
in class QueuePlacementRule
args
- Additional attributes of the rule's xml element other than create.public void initializeFromXml(Element el) throws AllocationConfigurationException
initializeFromXml
in class QueuePlacementRule
AllocationConfigurationException
protected String getQueueForApp(String requestedQueue, String user, org.apache.hadoop.security.Groups groups, Map<FSQueueType,Set<String>> configuredQueues)
QueuePlacementRule
getQueueForApp
in class QueuePlacementRule
requestedQueue
- The queue specified in the ApplicationSubmissionContextuser
- The user submitting the app.groups
- The groups of the user submitting the app.public boolean isTerminal()
QueuePlacementRule
isTerminal
in class QueuePlacementRule
Copyright © 2017 Apache Software Foundation. All Rights Reserved.