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

x33g5p2x  于2022-01-17 转载在 其他  
字(4.7k)|赞(0)|评价(0)|浏览(118)

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

AllocationConfiguration.isReservable介绍

暂无

代码示例

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

@Override
public Set<String> getPlanQueues() throws YarnException {
 Set<String> planQueues = new HashSet<String>();
 for (FSQueue fsQueue : queueMgr.getQueues()) {
  String queueName = fsQueue.getName();
  if (allocConf.isReservable(queueName)) {
   planQueues.add(queueName);
  }
 }
 return planQueues;
}

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

@Override
public Set<String> getPlanQueues() throws YarnException {
 Set<String> planQueues = new HashSet<String>();
 for (FSQueue fsQueue : queueMgr.getQueues()) {
  String queueName = fsQueue.getName();
  if (allocConf.isReservable(queueName)) {
   planQueues.add(queueName);
  }
 }
 return planQueues;
}

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

@Override
public Set<String> getPlanQueues() throws YarnException {
 Set<String> planQueues = new HashSet<String>();
 for (FSQueue fsQueue : queueMgr.getQueues()) {
  String queueName = fsQueue.getName();
  if (allocConf.isReservable(queueName)) {
   planQueues.add(queueName);
  }
 }
 return planQueues;
}

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

private String handleMoveToPlanQueue(String targetQueueName) {
  FSQueue dest = queueMgr.getQueue(targetQueueName);
  if (dest != null && allocConf.isReservable(dest.getQueueName())) {
   // use the default child reservation queue of the plan
   targetQueueName = getDefaultQueueForPlanQueue(targetQueueName);
  }
  return targetQueueName;
 }
}

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

private String handleMoveToPlanQueue(String targetQueueName) {
 FSQueue dest = queueMgr.getQueue(targetQueueName);
 if (dest != null && allocConf.isReservable(dest.getQueueName())) {
  // use the default child reservation queue of the plan
  targetQueueName = getDefaultQueueForPlanQueue(targetQueueName);
 }
 return targetQueueName;
}

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

private String handleMoveToPlanQueue(String targetQueueName) {
  FSQueue dest = queueMgr.getQueue(targetQueueName);
  if (dest != null && allocConf.isReservable(dest.getQueueName())) {
   // use the default child reservation queue of the plan
   targetQueueName = getDefaultQueueForPlanQueue(targetQueueName);
  }
  return targetQueueName;
 }
}

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

try {
 FSQueue queue = queueMgr.getQueue(queueName);
 if ((queue == null) || !allocConf.isReservable(queue.getQueueName())) {
  return queueName;

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

String reservableQueueName = "root.reservable";
String nonreservableQueueName = "root.other";
assertFalse(allocConf.isReservable(nonreservableQueueName));
assertTrue(allocConf.isReservable(reservableQueueName));

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

String reservableQueueName = "root.reservable";
String nonreservableQueueName = "root.other";
assertFalse(allocConf.isReservable(nonreservableQueueName));
assertTrue(allocConf.isReservable(reservableQueueName));
Map<FSQueueType, Set<String>> configuredQueues =
  allocConf.getConfiguredQueues();

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

private synchronized String resolveReservationQueueName(String queueName,
  ApplicationId applicationId, ReservationId reservationID) {
 FSQueue queue = queueMgr.getQueue(queueName);
 if ((queue == null) || !allocConf.isReservable(queue.getQueueName())) {
  return queueName;

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

private synchronized String resolveReservationQueueName(String queueName,
  ApplicationId applicationId, ReservationId reservationID) {
 FSQueue queue = queueMgr.getQueue(queueName);
 if ((queue == null) || !allocConf.isReservable(queue.getQueueName())) {
  return queueName;

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

if (allocConf.isReservable(queueName) &&
  !allocConf.getShowReservationAsQueues(queueName)) {
 return;

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

if (allocConf.isReservable(queueName) &&
  !allocConf.getShowReservationAsQueues(queueName)) {
 return;

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

reservedContainers = queue.getMetrics().getReservedContainers();
if (allocConf.isReservable(queueName) &&
  !allocConf.getShowReservationAsQueues(queueName)) {
 return;

相关文章

微信公众号

最新文章

更多