Package org.apache.hadoop.yarn.server.resourcemanager.security

Class CapacityQueueACLsManager

java.lang.Object
org.apache.hadoop.yarn.server.resourcemanager.security.QueueACLsManager
org.apache.hadoop.yarn.server.resourcemanager.security.CapacityQueueACLsManager
public class CapacityQueueACLsManager extends QueueACLsManager
This is the implementation of QueueACLsManager based on the CapacityScheduler.

  • Constructor Details

    • CapacityQueueACLsManager

      public CapacityQueueACLsManager(ResourceScheduler scheduler, org.apache.hadoop.conf.Configuration conf)

  • Method Details

    • checkAccess

      public boolean checkAccess(org.apache.hadoop.security.UserGroupInformation callerUGI, org.apache.hadoop.yarn.api.records.QueueACL acl, RMApp app, String remoteAddress, List<String> forwardedAddresses)
      Specified by:
      checkAccess in class QueueACLsManager

    • checkAccess

      public 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)
      Description copied from class: QueueACLsManager
      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.
      Specified by:
      checkAccess in class QueueACLsManager
      Parameters:
      callerUGI - the caller UGI
      acl - the acl for the Queue to check
      app - the application to move
      remoteAddress - server ip address
      forwardedAddresses - forwarded adresses
      targetQueue - 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)