org.apache.hadoop.mapred.QueueManager.toFullPropertyName()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(8.1k)|赞(0)|评价(0)|浏览(110)

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

QueueManager.toFullPropertyName介绍

暂无

代码示例

代码示例来源：origin: io.prestosql.hadoop/hadoop-apache

/**
 * Only applicable to leaf level queues
 * Parse ACLs for the queue from the configuration.
 */
private QueueState getQueueState(String name, Configuration conf) {
 String stateVal = conf.get(
   toFullPropertyName(name, "state"),
   QueueState.RUNNING.getStateName());
 return QueueState.getState(stateVal);
}

代码示例来源：origin: io.hops/hadoop-mapreduce-client-core

/**
 * Only applicable to leaf level queues
 * Parse ACLs for the queue from the configuration.
 */
private QueueState getQueueState(String name, Configuration conf) {
 String stateVal = conf.get(
   toFullPropertyName(name, "state"),
   QueueState.RUNNING.getStateName());
 return QueueState.getState(stateVal);
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-mapreduce-client-core

/**
 * Only applicable to leaf level queues
 * Parse ACLs for the queue from the configuration.
 */
private QueueState getQueueState(String name, Configuration conf) {
 String stateVal = conf.get(
   toFullPropertyName(name, "state"),
   QueueState.RUNNING.getStateName());
 return QueueState.getState(stateVal);
}

代码示例来源：origin: com.facebook.hadoop/hadoop-core

private void checkDeprecation(Configuration conf) {
 for(String queue: queueNames) {
  for (QueueOperation oper : QueueOperation.values()) {
   String key = toFullPropertyName(queue, oper.getAclName());
   String aclString = conf.get(key);
   if(aclString != null) {
    LOG.warn("Configuring queue ACLs in mapred-site.xml or " +
        "hadoop-site.xml is deprecated. Configure queue ACLs in " + 
        QUEUE_ACLS_FILE_NAME);
    return;
   }
  }
 }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-mapreduce-client-core

/**
 * Only applicable to leaf level queues
 * Parse ACLs for the queue from the configuration.
 */
private QueueState getQueueState(String name, Configuration conf) {
 String stateVal = conf.get(
   toFullPropertyName(name, "state"),
   QueueState.RUNNING.getStateName());
 return QueueState.getState(stateVal);
}

代码示例来源：origin: org.apache.hadoop/hadoop-mapred

/**
 * Only applicable to leaf level queues
 * Parse ACLs for the queue from the configuration.
 */
private QueueState getQueueState(String name, Configuration conf) {
 String stateVal = conf.get(
   toFullPropertyName(name, "state"),
   QueueState.RUNNING.getStateName());
 return QueueState.getState(stateVal);
}

代码示例来源：origin: io.prestosql.hadoop/hadoop-apache

/**
  * Parse ACLs for the queue from the configuration.
  */
 private Map<String, AccessControlList> getQueueAcls(
  String name,
  Configuration conf) {
  HashMap<String, AccessControlList> map =
   new HashMap<String, AccessControlList>();
  for (QueueACL qAcl : QueueACL.values()) {
   String aclKey = toFullPropertyName(name, qAcl.getAclName());
   map.put(
    aclKey, new AccessControlList(
     conf.get(
      aclKey, "*")));
  }
  return map;
 }
}

代码示例来源：origin: com.facebook.hadoop/hadoop-core

private HashMap<String, AccessControlList> getQueueAcls(Configuration conf)  {
 checkDeprecation(conf);
 conf.addResource(QUEUE_ACLS_FILE_NAME);
 HashMap<String, AccessControlList> aclsMap = 
  new HashMap<String, AccessControlList>();
 for (String queue : queueNames) {
  for (QueueOperation oper : QueueOperation.values()) {
   String key = toFullPropertyName(queue, oper.getAclName());
   String aclString = conf.get(key, "*");
   aclsMap.put(key, new AccessControlList(aclString));
  }
 } 
 return aclsMap;
}

代码示例来源：origin: io.hops/hadoop-mapreduce-client-core

/**
  * Parse ACLs for the queue from the configuration.
  */
 private Map<String, AccessControlList> getQueueAcls(
  String name,
  Configuration conf) {
  HashMap<String, AccessControlList> map =
   new HashMap<String, AccessControlList>();
  for (QueueACL qAcl : QueueACL.values()) {
   String aclKey = toFullPropertyName(name, qAcl.getAclName());
   map.put(
    aclKey, new AccessControlList(
     conf.get(
      aclKey, "*")));
  }
  return map;
 }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-mapreduce-client-core

/**
  * Parse ACLs for the queue from the configuration.
  */
 private Map<String, AccessControlList> getQueueAcls(
  String name,
  Configuration conf) {
  HashMap<String, AccessControlList> map =
   new HashMap<String, AccessControlList>();
  for (QueueACL qAcl : QueueACL.values()) {
   String aclKey = toFullPropertyName(name, qAcl.getAclName());
   map.put(
    aclKey, new AccessControlList(
     conf.get(
      aclKey, "*")));
  }
  return map;
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-mapreduce-client-core

/**
  * Parse ACLs for the queue from the configuration.
  */
 private Map<String, AccessControlList> getQueueAcls(
  String name,
  Configuration conf) {
  HashMap<String, AccessControlList> map =
   new HashMap<String, AccessControlList>();
  for (QueueACL qAcl : QueueACL.values()) {
   String aclKey = toFullPropertyName(name, qAcl.getAclName());
   map.put(
    aclKey, new AccessControlList(
     conf.get(
      aclKey, "*")));
  }
  return map;
 }
}

代码示例来源：origin: org.jvnet.hudson.hadoop/hadoop-core

private void initialize(Configuration conf) {
 aclsEnabled = conf.getBoolean("mapred.acls.enabled", false);
 String[] queues = conf.getStrings("mapred.queue.names", 
                new String[] {JobConf.DEFAULT_QUEUE_NAME});
 addToSet(queueNames, queues);
 
 // for every queue, and every operation, get the ACL
 // if any is specified and store in aclsMap.
 for (String queue : queues) {
  for (QueueOperation oper : QueueOperation.values()) {
   String key = toFullPropertyName(queue, oper.getAclName());
   String aclString = conf.get(key, "*");
   aclsMap.put(key, new ACL(aclString));
  }
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-mapred

/**
  * Parse ACLs for the queue from the configuration.
  */
 private Map<String, AccessControlList> getQueueAcls(
  String name,
  Configuration conf) {
  HashMap<String, AccessControlList> map =
   new HashMap<String, AccessControlList>();
  for (QueueACL qAcl : QueueACL.values()) {
   String aclKey = toFullPropertyName(name, qAcl.getAclName());
   map.put(
    aclKey, new AccessControlList(
     conf.get(
      aclKey, "*")));
  }
  return map;
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-mapred-test

protected void validateJobACLsFileContent() {
 JobConf jobACLsConf = TaskLogServlet.getConfFromJobACLsFile(jobId);
 assertTrue(jobACLsConf.get("user.name").equals(
   localizedJobConf.getUser()));
 assertTrue(jobACLsConf.get(MRJobConfig.JOB_ACL_VIEW_JOB).
   equals(localizedJobConf.get(MRJobConfig.JOB_ACL_VIEW_JOB)));
 String queue = localizedJobConf.getQueueName();
 assertTrue(queue.equalsIgnoreCase(jobACLsConf.getQueueName()));
 String qACLName = toFullPropertyName(queue,
   QueueACL.ADMINISTER_JOBS.getAclName());
 assertTrue(jobACLsConf.get(qACLName).equals(
   localizedJobConf.get(qACLName)));
}

代码示例来源：origin: org.apache.hadoop/hadoop-mapred

/**
 * Returns the specific queue ACL for the given queue.
 * Returns null if the given queue does not exist or the acl is not
 * configured for that queue.
 * If acls are disabled(mapreduce.cluster.acls.enabled set to false), returns
 * ACL with all users.
 */
synchronized AccessControlList getQueueACL(String queueName,
  QueueACL qACL) {
 if (areAclsEnabled) {
  Queue q = leafQueues.get(queueName);
  if (q != null) {
   return q.getAcls().get(toFullPropertyName(
    queueName, qACL.getAclName()));
  }
  else {
   LOG.warn("Queue " + queueName + " is not present.");
   return null;
  }
 }
 return new AccessControlList("*");
}

代码示例来源：origin: ch.cern.hadoop/hadoop-mapreduce-client-core

for (String queue : queues) {
 for (QueueACL qAcl : QueueACL.values()) {
  String key = toFullPropertyName(queue, qAcl.getAclName());
  String aclString = conf.get(key);
  if (aclString != null) {

代码示例来源：origin: io.hops/hadoop-mapreduce-client-core

LOG.debug("Checking access for the acl " + toFullPropertyName(queueName,
  qACL.getAclName()) + " for user " + ugi.getShortUserName());
  toFullPropertyName(queueName, qACL.getAclName()));
if (acl == null) {
 return false;

代码示例来源：origin: org.apache.hadoop/hadoop-mapred

LOG.debug("Checking access for the acl " + toFullPropertyName(queueName,
  qACL.getAclName()) + " for user " + ugi.getShortUserName());
  toFullPropertyName(queueName, qACL.getAclName()));
if (acl == null) {
 return false;

代码示例来源：origin: com.github.jiayuhan-it/hadoop-mapreduce-client-core

LOG.debug("Checking access for the acl " + toFullPropertyName(queueName,
  qACL.getAclName()) + " for user " + ugi.getShortUserName());
  toFullPropertyName(queueName, qACL.getAclName()));
if (acl == null) {
 return false;

代码示例来源：origin: org.apache.hadoop/hadoop-mapred

conf.get(toFullPropertyName(queue,
  QueueACL.ADMINISTER_JOBS.getAclName()), " "));

内容来源于网络，如有侵权，请联系作者删除！

QueueManager

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com