org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.AllocationConfiguration.getQueueAcl()方法的使用及代码示例

x33g5p2x  于2022-01-17 转载在 其他  
字(2.9k)|赞(0)|评价(0)|浏览(95)

本文整理了Java中org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.AllocationConfiguration.getQueueAcl()方法的一些代码示例,展示了AllocationConfiguration.getQueueAcl()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。AllocationConfiguration.getQueueAcl()方法的具体详情如下:
包路径:org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.AllocationConfiguration
类名称:AllocationConfiguration
方法名:getQueueAcl

AllocationConfiguration.getQueueAcl介绍

[英]Get the ACLs associated with this queue. If a given ACL is not explicitly configured, include the default value for that ACL. The default for the root queue is everybody ("") and the default for all other queues is nobody ("")
[中]获取与此队列关联的ACL。如果未明确配置给定ACL,请包含该ACL的默认值。根队列的默认值为Everyone(“
”),所有其他队列的默认值为nobody(“”)

代码示例

代码示例来源:origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

public boolean hasAccess(String queueName, QueueACL acl,
  UserGroupInformation user) {
 int lastPeriodIndex = queueName.length();
 while (lastPeriodIndex != -1) {
  String queue = queueName.substring(0, lastPeriodIndex);
  if (getQueueAcl(queue, acl).isUserAllowed(user)) {
   return true;
  }
  lastPeriodIndex = queueName.lastIndexOf('.', lastPeriodIndex - 1);
 }
 
 return false;
}

代码示例来源:origin: com.github.jiayuhan-it/hadoop-yarn-server-resourcemanager

public boolean hasAccess(String queueName, QueueACL acl,
  UserGroupInformation user) {
 int lastPeriodIndex = queueName.length();
 while (lastPeriodIndex != -1) {
  String queue = queueName.substring(0, lastPeriodIndex);
  if (getQueueAcl(queue, acl).isUserAllowed(user)) {
   return true;
  }
  lastPeriodIndex = queueName.lastIndexOf('.', lastPeriodIndex - 1);
 }
 
 return false;
}

代码示例来源:origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

assertEquals(" ", queueConf.getQueueAcl("root.queueA",
  QueueACL.ADMINISTER_QUEUE).getAclString());
assertEquals(" ", queueConf.getQueueAcl("root.queueA",
  QueueACL.SUBMIT_APPLICATIONS).getAclString());
assertEquals("alice,bob admins", queueConf.getQueueAcl("root.queueB",
  QueueACL.ADMINISTER_QUEUE).getAclString());
assertEquals("alice,bob admins", queueConf.getQueueAcl("root.queueC",
  QueueACL.SUBMIT_APPLICATIONS).getAclString());

代码示例来源:origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

assertEquals("*", queueConf.getQueueAcl("root",
  QueueACL.ADMINISTER_QUEUE).getAclString());
assertEquals("*", queueConf.getQueueAcl("root",
  QueueACL.SUBMIT_APPLICATIONS).getAclString());
assertEquals(" ", queueConf.getQueueAcl("root.queueA",
  QueueACL.ADMINISTER_QUEUE).getAclString());
assertEquals(" ", queueConf.getQueueAcl("root.queueA",
  QueueACL.SUBMIT_APPLICATIONS).getAclString());
assertEquals("alice,bob admins", queueConf.getQueueAcl("root.queueB",
  QueueACL.ADMINISTER_QUEUE).getAclString());
assertEquals("alice,bob admins", queueConf.getQueueAcl("root.queueC",
  QueueACL.SUBMIT_APPLICATIONS).getAclString());

相关文章

微信公众号

最新文章

更多