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

QueueMetrics.unreserveResource介绍

暂无

代码示例

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

public void unreserveResource(String partition, String user, Resource res) {
 if(partition == null || partition.equals(RMNodeLabelsManager.NO_LABEL)) {
  unreserveResource(user, res);
 }
}

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

public void unreserveResource(String user, Resource res) {
 reservedContainers.decr();
 reservedMB.decr(res.getMemory());
 reservedVCores.decr(res.getVirtualCores());
 QueueMetrics userMetrics = getUserMetrics(user);
 if (userMetrics != null) {
  userMetrics.unreserveResource(user, res);
 }
 if (parent != null) {
  parent.unreserveResource(user, res);
 }
}

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

public void unreserveResource(String user, Resource res) {
 reservedContainers.decr();
 reservedMB.decr(res.getMemorySize());
 reservedVCores.decr(res.getVirtualCores());
 QueueMetrics userMetrics = getUserMetrics(user);
 if (userMetrics != null) {
  userMetrics.unreserveResource(user, res);
 }
 if (parent != null) {
  parent.unreserveResource(user, res);
 }
}

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

public void unreserveResource(String user, Resource res) {
 reservedContainers.decr();
 reservedMB.decr(res.getMemory());
 reservedVCores.decr(res.getVirtualCores());
 QueueMetrics userMetrics = getUserMetrics(user);
 if (userMetrics != null) {
  userMetrics.unreserveResource(user, res);
 }
 if (parent != null) {
  parent.unreserveResource(user, res);
 }
}

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

public synchronized void move(Queue newQueue) {
 QueueMetrics oldMetrics = queue.getMetrics();
 QueueMetrics newMetrics = newQueue.getMetrics();
 String user = getUser();
 for (RMContainer liveContainer : liveContainers.values()) {
  Resource resource = liveContainer.getContainer().getResource();
  oldMetrics.releaseResources(user, 1, resource);
  newMetrics.allocateResources(user, 1, resource, false);
 }
 for (Map<NodeId, RMContainer> map : reservedContainers.values()) {
  for (RMContainer reservedContainer : map.values()) {
   Resource resource = reservedContainer.getReservedResource();
   oldMetrics.unreserveResource(user, resource);
   newMetrics.reserveResource(user, resource);
  }
 }
 appSchedulingInfo.move(newQueue);
 this.queue = newQueue;
}

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

private boolean unreserve(FiCaSchedulerApp application, Priority priority,
  FiCaSchedulerNode node, RMContainer rmContainer) {
 // Done with the reservation?
 if (application.unreserve(node, priority)) {
  node.unreserveResource(application);
  // Update reserved metrics
  getMetrics().unreserveResource(application.getUser(),
    rmContainer.getContainer().getResource());
  return true;
 }
 return false;
}

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

public synchronized void move(Queue newQueue) {
 QueueMetrics oldMetrics = queue.getMetrics();
 QueueMetrics newMetrics = newQueue.getMetrics();
 String user = getUser();
 for (RMContainer liveContainer : liveContainers.values()) {
  Resource resource = liveContainer.getContainer().getResource();
  oldMetrics.releaseResources(user, 1, resource);
  newMetrics.allocateResources(user, 1, resource, false);
 }
 for (Map<NodeId, RMContainer> map : reservedContainers.values()) {
  for (RMContainer reservedContainer : map.values()) {
   Resource resource = reservedContainer.getReservedResource();
   oldMetrics.unreserveResource(user, resource);
   newMetrics.reserveResource(user, resource);
  }
 }
 appSchedulingInfo.move(newQueue);
 this.queue = newQueue;
}

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

private boolean unreserve(FiCaSchedulerApp application, Priority priority,
  FiCaSchedulerNode node, RMContainer rmContainer) {
 // Done with the reservation?
 if (application.unreserve(node, priority)) {
  node.unreserveResource(application);
  // Update reserved metrics
  getMetrics().unreserveResource(application.getUser(),
    rmContainer.getContainer().getResource());
  return true;
 }
 return false;
}

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

/**
 * Remove the reservation on {@code node} at the given {@link Priority}.
 * This dispatches SchedulerNode handlers as well.
 */
public void unreserve(Priority priority, FSSchedulerNode node) {
 RMContainer rmContainer = node.getReservedContainer();
 unreserveInternal(priority, node);
 node.unreserveResource(this);
 getMetrics().unreserveResource(
   getUser(), rmContainer.getContainer().getResource());
}

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

public boolean unreserve(SchedulerRequestKey schedulerKey,
  FiCaSchedulerNode node, RMContainer rmContainer) {
 try {
  writeLock.lock();
  // Done with the reservation?
  if (internalUnreserve(node, schedulerKey)) {
   node.unreserveResource(this);
   // Update reserved metrics
   queue.getMetrics().unreserveResource(node.getPartition(),
     getUser(), rmContainer.getReservedResource());
   queue.decReservedResource(node.getPartition(),
     rmContainer.getReservedResource());
   return true;
  }
  return false;
 } finally {
  writeLock.unlock();
 }
}

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

/**
 * Remove the reservation on {@code node} at the given {@link Priority}.
 * This dispatches SchedulerNode handlers as well.
 */
public void unreserve(Priority priority, FSSchedulerNode node) {
 RMContainer rmContainer = node.getReservedContainer();
 unreserveInternal(priority, node);
 node.unreserveResource(this);
 getMetrics().unreserveResource(
   getUser(), rmContainer.getContainer().getResource());
}

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

((RMContainerImpl) reservedContainer).setQueueName(newQueueName);
Resource resource = reservedContainer.getReservedResource();
oldMetrics.unreserveResource(
  reservedContainer.getNodeLabelExpression(), user, resource);
newMetrics.reserveResource(

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

/**
 * Remove the reservation on {@code node} at the given SchedulerRequestKey.
 * This dispatches SchedulerNode handlers as well.
 * @param schedulerKey Scheduler Key
 * @param node Node
 */
public void unreserve(SchedulerRequestKey schedulerKey,
  FSSchedulerNode node) {
 RMContainer rmContainer = node.getReservedContainer();
 unreserveInternal(schedulerKey, node);
 node.unreserveResource(this);
 clearReservation(node);
 getMetrics().unreserveResource(node.getPartition(),
   getUser(), rmContainer.getContainer().getResource());
}

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

metrics.unreserveResource(RMNodeLabelsManager.NO_LABEL,
   user, Resources.createResource(3*GB, 3));
checkResources(queueSource, 4*GB, 4, 2, 3, 1, 100*GB, 100, 9*GB, 9, 2, 0, 0, 0);

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

metrics.unreserveResource(user, Resources.createResource(3*GB, 3));
checkResources(queueSource, 4*GB, 4, 2, 3, 1, 100*GB, 100, 9*GB, 9, 2, 0, 0, 0);
checkResources(parentQueueSource, 4*GB, 4, 2, 3, 1, 100*GB, 100, 9*GB, 9, 2, 0, 0, 0);