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

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

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

QueuePlacementPolicy.createAndInitializeRule介绍

[英]Create and initialize a rule given a xml node
[中]创建并初始化给定xml节点的规则

代码示例

代码示例来源:origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

/**
 * Builds a QueuePlacementPolicy from an xml element.
 */
public static QueuePlacementPolicy fromXml(Element el,
  Map<FSQueueType, Set<String>> configuredQueues, Configuration conf)
  throws AllocationConfigurationException {
 List<QueuePlacementRule> rules = new ArrayList<QueuePlacementRule>();
 NodeList elements = el.getChildNodes();
 for (int i = 0; i < elements.getLength(); i++) {
  Node node = elements.item(i);
  if (node instanceof Element) {
   QueuePlacementRule rule = createAndInitializeRule(node);
   rules.add(rule);
  }
 }
 return new QueuePlacementPolicy(rules, configuredQueues, conf);
}

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

/**
 * Builds a QueuePlacementPolicy from an xml element.
 */
public static QueuePlacementPolicy fromXml(Element el,
  Map<FSQueueType, Set<String>> configuredQueues, Configuration conf)
  throws AllocationConfigurationException {
 List<QueuePlacementRule> rules = new ArrayList<QueuePlacementRule>();
 NodeList elements = el.getChildNodes();
 for (int i = 0; i < elements.getLength(); i++) {
  Node node = elements.item(i);
  if (node instanceof Element) {
   QueuePlacementRule rule = createAndInitializeRule(node);
   rules.add(rule);
  }
 }
 return new QueuePlacementPolicy(rules, configuredQueues, conf);
}

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

/**
 * Builds a QueuePlacementPolicy from an xml element.
 */
public static QueuePlacementPolicy fromXml(Element el,
  Map<FSQueueType, Set<String>> configuredQueues, Configuration conf)
  throws AllocationConfigurationException {
 List<QueuePlacementRule> rules = new ArrayList<QueuePlacementRule>();
 NodeList elements = el.getChildNodes();
 for (int i = 0; i < elements.getLength(); i++) {
  Node node = elements.item(i);
  if (node instanceof Element) {
   QueuePlacementRule rule = createAndInitializeRule(node);
   rules.add(rule);
  }
 }
 return new QueuePlacementPolicy(rules, configuredQueues, conf);
}

代码示例来源:origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

if ("rule".equals(element.getTagName())) {
 QueuePlacementRule rule = QueuePlacementPolicy
   .createAndInitializeRule(node);
 if (rule == null) {
  throw new AllocationConfigurationException(

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

if ("rule".equals(element.getTagName())) {
 QueuePlacementRule rule = QueuePlacementPolicy
   .createAndInitializeRule(node);
 if (rule == null) {
  throw new AllocationConfigurationException(

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

if ("rule".equals(element.getTagName())) {
 QueuePlacementRule rule = QueuePlacementPolicy
   .createAndInitializeRule(node);
 if (rule == null) {
  throw new AllocationConfigurationException(

相关文章