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

QueuePlacementPolicy.getRules介绍

暂无

代码示例

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

@Test
public void testSimplePlacementPolicyFromConf() throws Exception {
 Configuration conf = new Configuration();
 conf.set(FairSchedulerConfiguration.ALLOCATION_FILE, ALLOC_FILE);
 conf.setBoolean(FairSchedulerConfiguration.ALLOW_UNDECLARED_POOLS, false);
 conf.setBoolean(FairSchedulerConfiguration.USER_AS_DEFAULT_QUEUE, false);
 
 PrintWriter out = new PrintWriter(new FileWriter(ALLOC_FILE));
 out.println("<?xml version=\"1.0\"?>");
 out.println("<allocations>");
 out.println("</allocations>");
 out.close();
 
 AllocationFileLoaderService allocLoader = new AllocationFileLoaderService();
 allocLoader.init(conf);
 ReloadListener confHolder = new ReloadListener();
 allocLoader.setReloadListener(confHolder);
 allocLoader.reloadAllocations();
 AllocationConfiguration allocConf = confHolder.allocConf;
 
 QueuePlacementPolicy placementPolicy = allocConf.getPlacementPolicy();
 List<QueuePlacementRule> rules = placementPolicy.getRules();
 assertEquals(2, rules.size());
 assertEquals(QueuePlacementRule.Specified.class, rules.get(0).getClass());
 assertEquals(false, rules.get(0).create);
 assertEquals(QueuePlacementRule.Default.class, rules.get(1).getClass());
}

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

@Test
public void testDefaultRuleInitializesProperlyWhenPolicyNotConfigured()
  throws IOException {
 // This test verifies if default rule in queue placement policy
 // initializes properly when policy is not configured and
 // undeclared pools is not allowed.
 conf.set(FairSchedulerConfiguration.ALLOCATION_FILE, ALLOC_FILE);
 conf.setBoolean(FairSchedulerConfiguration.ALLOW_UNDECLARED_POOLS, false);
 // Create an alloc file with no queue placement policy
 PrintWriter out = new PrintWriter(new FileWriter(ALLOC_FILE));
 out.println("<?xml version=\"1.0\"?>");
 out.println("<allocations>");
 out.println("</allocations>");
 out.close();
 scheduler.init(conf);
 scheduler.start();
 scheduler.reinitialize(conf, resourceManager.getRMContext());
 List<QueuePlacementRule> rules =
   scheduler.allocConf.placementPolicy.getRules();
 for (QueuePlacementRule rule : rules) {
  if (rule instanceof Default) {
   Default defaultRule = (Default) rule;
   assertNotNull(defaultRule.defaultQueueName);
  }
 }
}

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

@Test
public void testDefaultRuleInitializesProperlyWhenPolicyNotConfigured()
  throws IOException {
 // This test verifies if default rule in queue placement policy
 // initializes properly when policy is not configured and
 // undeclared pools is not allowed.
 conf.set(FairSchedulerConfiguration.ALLOCATION_FILE, ALLOC_FILE);
 conf.setBoolean(FairSchedulerConfiguration.ALLOW_UNDECLARED_POOLS, false);
 // Create an alloc file with no queue placement policy
 PrintWriter out = new PrintWriter(new FileWriter(ALLOC_FILE));
 out.println("<?xml version=\"1.0\"?>");
 out.println("<allocations>");
 out.println("</allocations>");
 out.close();
 scheduler.init(conf);
 scheduler.start();
 scheduler.reinitialize(conf, resourceManager.getRMContext());
 List<QueuePlacementRule> rules = scheduler.allocConf.placementPolicy
   .getRules();
 for (QueuePlacementRule rule : rules) {
  if (rule instanceof Default) {
   Default defaultRule = (Default) rule;
   assertNotNull(defaultRule.defaultQueueName);
  }
 }
}

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

@Test
public void testSimplePlacementPolicyFromConf() throws Exception {
 Configuration conf = new Configuration();
 conf.set(FairSchedulerConfiguration.ALLOCATION_FILE, ALLOC_FILE);
 conf.setBoolean(FairSchedulerConfiguration.ALLOW_UNDECLARED_POOLS, false);
 conf.setBoolean(FairSchedulerConfiguration.USER_AS_DEFAULT_QUEUE, false);
 PrintWriter out = new PrintWriter(new FileWriter(ALLOC_FILE));
 out.println("<?xml version=\"1.0\"?>");
 out.println("<allocations>");
 out.println("</allocations>");
 out.close();
 AllocationFileLoaderService allocLoader = new AllocationFileLoaderService();
 allocLoader.init(conf);
 ReloadListener confHolder = new ReloadListener();
 allocLoader.setReloadListener(confHolder);
 allocLoader.reloadAllocations();
 AllocationConfiguration allocConf = confHolder.allocConf;
 QueuePlacementPolicy placementPolicy = allocConf.getPlacementPolicy();
 List<QueuePlacementRule> rules = placementPolicy.getRules();
 assertEquals(2, rules.size());
 assertEquals(QueuePlacementRule.Specified.class, rules.get(0).getClass());
 assertEquals(false, rules.get(0).create);
 assertEquals(QueuePlacementRule.Default.class, rules.get(1).getClass());
}

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

List<QueuePlacementRule> rules = policy.getRules();
assertEquals(1, rules.size());
assertEquals(QueuePlacementRule.Default.class, rules.get(0).getClass());
rules = policy.getRules();
assertEquals(3, rules.size());
assertEquals(QueuePlacementRule.Specified.class, rules.get(0).getClass());

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

List<QueuePlacementRule> rules = policy.getRules();
assertEquals(1, rules.size());
assertEquals(QueuePlacementRule.Default.class, rules.get(0).getClass());
rules = policy.getRules();
assertEquals(3, rules.size());
assertEquals(QueuePlacementRule.Specified.class, rules.get(0).getClass());