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

QueueManager.ensureRootPrefix介绍

暂无

代码示例

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

/**
 * Gets a queue by name.
 */
public FSQueue getQueue(String name) {
 name = ensureRootPrefix(name);
 synchronized (queues) {
  return queues.get(name);
 }
}

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

/**
 * Return whether a queue exists already.
 */
public boolean exists(String name) {
 name = ensureRootPrefix(name);
 synchronized (queues) {
  return queues.containsKey(name);
 }
}

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

/**
 * Return whether a queue exists already.
 */
public boolean exists(String name) {
 name = ensureRootPrefix(name);
 synchronized (queues) {
  return queues.containsKey(name);
 }
}

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

/**
 * Gets a queue by name.
 */
public FSQueue getQueue(String name) {
 name = ensureRootPrefix(name);
 synchronized (queues) {
  return queues.get(name);
 }
}

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

/**
 * Gets a queue by name.
 */
public FSQueue getQueue(String name) {
 name = ensureRootPrefix(name);
 synchronized (queues) {
  return queues.get(name);
 }
}

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

/**
 * Return whether a queue exists already.
 */
public boolean exists(String name) {
 name = ensureRootPrefix(name);
 synchronized (queues) {
  return queues.containsKey(name);
 }
}

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

/**
 * Remove a leaf queue if empty
 * @param name name of the queue
 * @return true if queue was removed or false otherwise
 */
public boolean removeLeafQueue(String name) {
 name = ensureRootPrefix(name);
 return removeEmptyIncompatibleQueues(name, FSQueueType.PARENT);
}

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

/**
 * Remove a leaf queue if empty
 * @param name name of the queue
 * @return true if queue was removed or false otherwise
 */
public boolean removeLeafQueue(String name) {
 name = ensureRootPrefix(name);
 return removeEmptyIncompatibleQueues(name, FSQueueType.PARENT);
}

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

/**
 * Remove a leaf queue if empty.
 * @param name name of the queue
 * @return true if queue was removed or false otherwise
 */
public boolean removeLeafQueue(String name) {
 name = ensureRootPrefix(name);
 return !Boolean.FALSE.equals(
   removeEmptyIncompatibleQueues(name, FSQueueType.PARENT).orElse(null));
}

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

private FSQueue getQueue(String name, boolean create, FSQueueType queueType) {
 name = ensureRootPrefix(name);
 synchronized (queues) {
  FSQueue queue = queues.get(name);
  if (queue == null && create) {
   // if the queue doesn't exist,create it and return
   queue = createQueue(name, queueType);
   // Update steady fair share for all queues
   if (queue != null) {
    rootQueue.recomputeSteadyShares();
   }
  }
  return queue;
 }
}

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

private FSQueue getQueue(String name, boolean create, FSQueueType queueType) {
 name = ensureRootPrefix(name);
 synchronized (queues) {
  FSQueue queue = queues.get(name);
  if (queue == null && create) {
   // if the queue doesn't exist,create it and return
   queue = createQueue(name, queueType);
   // Update steady fair share for all queues
   if (queue != null) {
    rootQueue.recomputeSteadyShares();
   }
  }
  return queue;
 }
}

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

queueToCreate = ensureRootPrefix(queueToCreate);

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

queueToCreate = ensureRootPrefix(queueToCreate);

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

queueToCreate = ensureRootPrefix(queueToCreate);

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

private FSQueue getQueue(String name, boolean create, FSQueueType queueType,
  boolean recomputeSteadyShares, ApplicationId applicationId) {
 boolean recompute = recomputeSteadyShares;
 name = ensureRootPrefix(name);
 FSQueue queue;
 synchronized (queues) {
  queue = queues.get(name);
  if (queue == null && create) {
   // if the queue doesn't exist,create it and return
   queue = createQueue(name, queueType);
  } else {
   recompute = false;
  }
  // At this point the queue exists and we need to assign the app if to the
  // but only to a leaf queue
  if (applicationId != null && queue instanceof FSLeafQueue) {
   ((FSLeafQueue)queue).addAssignedApp(applicationId);
  }
 }
 // Don't recompute if it is an existing queue or no change was made
 if (recompute && queue != null) {
  rootQueue.recomputeSteadyShares();
 }
 return queue;
}