Class QueueACLsManager
java.lang.Object
org.apache.hadoop.yarn.server.resourcemanager.security.QueueACLsManager
- Direct Known Subclasses:
CapacityQueueACLsManager,FairQueueACLsManager,GenericQueueACLsManager
-
Constructor Summary
ConstructorsConstructorDescriptionQueueACLsManager(org.apache.hadoop.conf.Configuration conf) QueueACLsManager(ResourceScheduler scheduler, org.apache.hadoop.conf.Configuration conf) -
Method Summary
Modifier and TypeMethodDescriptionabstract booleancheckAccess(org.apache.hadoop.security.UserGroupInformation callerUGI, org.apache.hadoop.yarn.api.records.QueueACL acl, RMApp app, String remoteAddress, List<String> forwardedAddresses) abstract booleancheckAccess(org.apache.hadoop.security.UserGroupInformation callerUGI, org.apache.hadoop.yarn.api.records.QueueACL acl, RMApp app, String remoteAddress, List<String> forwardedAddresses, String targetQueue) Check access to a targetQueue in the case of a move of an application.static QueueACLsManagergetQueueACLsManager(ResourceScheduler scheduler, org.apache.hadoop.conf.Configuration conf) Get queue acl manager corresponding to the scheduler.
-
Constructor Details
-
QueueACLsManager
@VisibleForTesting public QueueACLsManager(org.apache.hadoop.conf.Configuration conf) -
QueueACLsManager
-
-
Method Details
-
getQueueACLsManager
public static QueueACLsManager getQueueACLsManager(ResourceScheduler scheduler, org.apache.hadoop.conf.Configuration conf) Get queue acl manager corresponding to the scheduler.- Parameters:
scheduler- the scheduler for which the queue acl manager is requiredconf- Configuration.- Returns:
QueueACLsManager
-
checkAccess
-
checkAccess
public abstract boolean checkAccess(org.apache.hadoop.security.UserGroupInformation callerUGI, org.apache.hadoop.yarn.api.records.QueueACL acl, RMApp app, String remoteAddress, List<String> forwardedAddresses, String targetQueue) Check access to a targetQueue in the case of a move of an application. The application cannot contain the destination queue since it has not been moved yet, thus need to pass it in separately.- Parameters:
callerUGI- the caller UGIacl- the acl for the Queue to checkapp- the application to moveremoteAddress- server ip addressforwardedAddresses- forwarded adressestargetQueue- the name of the queue to move the application to- Returns:
- true: if submission is allowed and queue exists, false: in all other cases (also non existing target queue)
-