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

AllocationConfiguration.getPlacementPolicy介绍

暂无

代码示例

代码示例来源：origin: apache/hive

allocConf.set(new AllocationConfiguration(conf));
QueuePlacementPolicy queuePolicy = allocConf.get().getPlacementPolicy();
if (queuePolicy != null) {
 requestedQueue = queuePolicy.assignAppToQueue(requestedQueue, userName);

代码示例来源：origin: com.github.hyukjinkwon.shims/hive-shims-scheduler

allocConf.set(new AllocationConfiguration(conf));
QueuePlacementPolicy queuePolicy = allocConf.get().getPlacementPolicy();
if (queuePolicy != null) {
 requestedQueue = queuePolicy.assignAppToQueue(requestedQueue, userName);

代码示例来源：origin: org.apache.hive.shims/hive-shims-scheduler

allocConf.set(new AllocationConfiguration(conf));
QueuePlacementPolicy queuePolicy = allocConf.get().getPlacementPolicy();
if (queuePolicy != null) {
 requestedQueue = queuePolicy.assignAppToQueue(requestedQueue, userName);

代码示例来源：origin: org.spark-project.hive.shims/hive-shims-scheduler

allocConf.set(new AllocationConfiguration(conf));
QueuePlacementPolicy queuePolicy = allocConf.get().getPlacementPolicy();
if (queuePolicy != null) {
 requestedQueue = queuePolicy.assignAppToQueue(requestedQueue, userName);

代码示例来源：origin: com.cloudera.llama/llama

/**
 * Assign reservation to a queue based on the placement policy specified
 * in the alloc conf
 */
// Visible for testing
String assignToQueue(TLlamaAMReservationRequest request)
  throws LlamaException {
 // Default means no queue requested
 String requestedQueue = (request.isSetQueue()) ? request.getQueue()
   : YarnConfiguration.DEFAULT_QUEUE_NAME;
 if (requestedQueue == null) {
  requestedQueue = YarnConfiguration.DEFAULT_QUEUE_NAME;
 }
 String user = request.getUser();
 String queue;
 try {
  queue = allocConf.get().getPlacementPolicy()
    .assignAppToQueue(requestedQueue, user);
 } catch (IOException ex) {
  throw new LlamaException(ex, ErrorCode.INTERNAL_ERROR);
 }
 if (queue == null) {
  throw new LlamaException(
    ErrorCode.RESERVATION_USER_TO_QUEUE_MAPPING_NOT_FOUND, user, requestedQueue);
 }
 LOG.debug("Reservation from user " + user + " with requested queue " +
   requestedQueue + " resolved to queue " + queue);
 
 return queue;
}

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

QueuePlacementPolicy placementPolicy = allocConf.getPlacementPolicy();
queueName = placementPolicy.assignAppToQueue(queueName, user);
if (queueName == null) {

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

QueuePlacementPolicy placementPolicy = allocConf.getPlacementPolicy();
queueName = placementPolicy.assignAppToQueue(queueName, user);
if (queueName == null) {

代码示例来源：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: org.apache.hadoop/hadoop-yarn-server-resourcemanager

QueuePlacementPolicy placementPolicy = allocConf.getPlacementPolicy();
queueName = placementPolicy.assignAppToQueue(queueName, user);
if (queueName == null) {

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

QueuePlacementPolicy policy = allocConf.getPlacementPolicy();
List<QueuePlacementRule> rules = policy.getRules();
assertEquals(1, rules.size());
policy = allocConf.getPlacementPolicy();
rules = policy.getRules();
assertEquals(3, rules.size());

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

QueuePlacementPolicy policy = allocConf.getPlacementPolicy();
List<QueuePlacementRule> rules = policy.getRules();
assertEquals(1, rules.size());
policy = allocConf.getPlacementPolicy();
rules = policy.getRules();
assertEquals(3, rules.size());