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

QueuePlacementPolicy.<init>介绍

暂无

代码示例

代码示例来源：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: com.github.jiayuhan-it/hadoop-yarn-server-resourcemanager

/**
 * Build a simple queue placement policy from the allow-undeclared-pools and
 * user-as-default-queue configuration options.
 */
public static QueuePlacementPolicy fromConfiguration(Configuration conf,
  Map<FSQueueType, Set<String>> configuredQueues) {
 boolean create = conf.getBoolean(
   FairSchedulerConfiguration.ALLOW_UNDECLARED_POOLS,
   FairSchedulerConfiguration.DEFAULT_ALLOW_UNDECLARED_POOLS);
 boolean userAsDefaultQueue = conf.getBoolean(
   FairSchedulerConfiguration.USER_AS_DEFAULT_QUEUE,
   FairSchedulerConfiguration.DEFAULT_USER_AS_DEFAULT_QUEUE);
 List<QueuePlacementRule> rules = new ArrayList<QueuePlacementRule>();
 rules.add(new QueuePlacementRule.Specified().initialize(create, null));
 if (userAsDefaultQueue) {
  rules.add(new QueuePlacementRule.User().initialize(create, null));
 }
 if (!userAsDefaultQueue || !create) {
  rules.add(new QueuePlacementRule.Default().initialize(true, null));
 }
 try {
  return new QueuePlacementPolicy(rules, configuredQueues, conf);
 } catch (AllocationConfigurationException ex) {
  throw new RuntimeException("Should never hit exception when loading" +
      "placement policy from conf", ex);
 }
}

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

/**
 * Build a simple queue placement policy from the allow-undeclared-pools and
 * user-as-default-queue configuration options.
 */
public static QueuePlacementPolicy fromConfiguration(Configuration conf,
  Map<FSQueueType, Set<String>> configuredQueues) {
 boolean create = conf.getBoolean(
   FairSchedulerConfiguration.ALLOW_UNDECLARED_POOLS,
   FairSchedulerConfiguration.DEFAULT_ALLOW_UNDECLARED_POOLS);
 boolean userAsDefaultQueue = conf.getBoolean(
   FairSchedulerConfiguration.USER_AS_DEFAULT_QUEUE,
   FairSchedulerConfiguration.DEFAULT_USER_AS_DEFAULT_QUEUE);
 List<QueuePlacementRule> rules = new ArrayList<QueuePlacementRule>();
 rules.add(new QueuePlacementRule.Specified().initialize(create, null));
 if (userAsDefaultQueue) {
  rules.add(new QueuePlacementRule.User().initialize(create, null));
 }
 if (!userAsDefaultQueue || !create) {
  rules.add(new QueuePlacementRule.Default().initialize(true, null));
 }
 try {
  return new QueuePlacementPolicy(rules, configuredQueues, conf);
 } catch (AllocationConfigurationException ex) {
  throw new RuntimeException("Should never hit exception when loading" +
      "placement policy from conf", ex);
 }
}

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

/**
 * Build a simple queue placement policy from the allow-undeclared-pools and
 * user-as-default-queue configuration options.
 */
public static QueuePlacementPolicy fromConfiguration(Configuration conf,
  Map<FSQueueType, Set<String>> configuredQueues) {
 boolean create = conf.getBoolean(
   FairSchedulerConfiguration.ALLOW_UNDECLARED_POOLS,
   FairSchedulerConfiguration.DEFAULT_ALLOW_UNDECLARED_POOLS);
 boolean userAsDefaultQueue = conf.getBoolean(
   FairSchedulerConfiguration.USER_AS_DEFAULT_QUEUE,
   FairSchedulerConfiguration.DEFAULT_USER_AS_DEFAULT_QUEUE);
 List<QueuePlacementRule> rules = new ArrayList<QueuePlacementRule>();
 rules.add(new QueuePlacementRule.Specified().initialize(create, null));
 if (userAsDefaultQueue) {
  rules.add(new QueuePlacementRule.User().initialize(create, null));
 }
 if (!userAsDefaultQueue || !create) {
  rules.add(new QueuePlacementRule.Default().initialize(true, null));
 }
 try {
  return new QueuePlacementPolicy(rules, configuredQueues, conf);
 } catch (AllocationConfigurationException ex) {
  throw new RuntimeException("Should never hit exception when loading" +
      "placement policy from conf", ex);
 }
}

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

configuredQueues.put(FSQueueType.PARENT, new HashSet<String>());
scheduler.getAllocationConfiguration().placementPolicy =
  new QueuePlacementPolicy(rules, configuredQueues, conf);
appId = createSchedulingRequest(1024, "somequeue", "user1");
assertEquals("root.somequeue", scheduler.getSchedulerApp(appId).getQueueName());
rules.add(new QueuePlacementRule.Default().initialize(true, null));
scheduler.getAllocationConfiguration().placementPolicy =
  new QueuePlacementPolicy(rules, configuredQueues, conf);
appId = createSchedulingRequest(1024, "somequeue", "user1");
assertEquals("root.user1", scheduler.getSchedulerApp(appId).getQueueName());

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

configuredQueues.put(FSQueueType.PARENT, new HashSet<String>());
scheduler.getAllocationConfiguration().placementPolicy =
  new QueuePlacementPolicy(rules, configuredQueues, conf);
appId = createSchedulingRequest(1024, "somequeue", "user1");
assertEquals("root.somequeue", scheduler.getSchedulerApp(appId).getQueueName());
rules.add(new QueuePlacementRule.Default().initialize(true, null));
scheduler.getAllocationConfiguration().placementPolicy =
  new QueuePlacementPolicy(rules, configuredQueues, conf);
appId = createSchedulingRequest(1024, "somequeue", "user1");
assertEquals("root.user1", scheduler.getSchedulerApp(appId).getQueueName());