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

QueueMetrics.reserveResource介绍

暂无

代码示例

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

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

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

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

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

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

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

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

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

private void reserve(FiCaSchedulerApp application, Priority priority, 
  FiCaSchedulerNode node, RMContainer rmContainer, Container container) {
 // Update reserved metrics if this is the first reservation
 if (rmContainer == null) {
  getMetrics().reserveResource(
    application.getUser(), container.getResource());
 }
 // Inform the application 
 rmContainer = application.reserve(node, priority, rmContainer, container);
 
 // Update the node
 node.reserveResource(application, priority, rmContainer);
}

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

private void reserve(FiCaSchedulerApp application, Priority priority, 
  FiCaSchedulerNode node, RMContainer rmContainer, Container container) {
 // Update reserved metrics if this is the first reservation
 if (rmContainer == null) {
  getMetrics().reserveResource(
    application.getUser(), container.getResource());
 }
 // Inform the application 
 rmContainer = application.reserve(node, priority, rmContainer, container);
 
 // Update the node
 node.reserveResource(application, priority, rmContainer);
}

代码示例来源：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

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: org.apache.hadoop/hadoop-yarn-server-resourcemanager

public void reserve(SchedulerRequestKey schedulerKey, FiCaSchedulerNode node,
  RMContainer rmContainer, Container container, boolean reReservation) {
 // Update reserved metrics if this is the first reservation
 // rmContainer will be moved to reserved in the super.reserve
 if (!reReservation) {
  queue.getMetrics().reserveResource(node.getPartition(),
    getUser(), container.getResource());
 }
 // Inform the application
 rmContainer = super.reserve(node, schedulerKey, rmContainer, container);
 // Update the node
 node.reserveResource(this, schedulerKey, rmContainer);
}

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

oldMetrics.unreserveResource(
  reservedContainer.getNodeLabelExpression(), user, resource);
newMetrics.reserveResource(
  reservedContainer.getNodeLabelExpression(), user, resource);

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

/**
 * Reserve a spot for {@code container} on this {@code node}. If
 * the container is {@code alreadyReserved} on the node, simply
 * update relevant bookeeping. This dispatches ro relevant handlers
 * in {@link FSSchedulerNode}..
 */
private void reserve(Priority priority, FSSchedulerNode node,
  Container container, boolean alreadyReserved) {
 LOG.info("Making reservation: node=" + node.getNodeName() +
   " app_id=" + getApplicationId());
 if (!alreadyReserved) {
  getMetrics().reserveResource(getUser(), container.getResource());
  RMContainer rmContainer =
    super.reserve(node, priority, null, container);
  node.reserveResource(this, priority, rmContainer);
 } else {
  RMContainer rmContainer = node.getReservedContainer();
  super.reserve(node, priority, rmContainer, container);
  node.reserveResource(this, priority, rmContainer);
 }
}

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

/**
 * Reserve a spot for {@code container} on this {@code node}. If
 * the container is {@code alreadyReserved} on the node, simply
 * update relevant bookeeping. This dispatches ro relevant handlers
 * in {@link FSSchedulerNode}..
 */
private void reserve(Priority priority, FSSchedulerNode node,
  Container container, boolean alreadyReserved) {
 LOG.info("Making reservation: node=" + node.getNodeName() +
   " app_id=" + getApplicationId());
 if (!alreadyReserved) {
  getMetrics().reserveResource(getUser(), container.getResource());
  RMContainer rmContainer =
    super.reserve(node, priority, null, container);
  node.reserveResource(this, priority, rmContainer);
 } else {
  RMContainer rmContainer = node.getReservedContainer();
  super.reserve(node, priority, rmContainer, container);
  node.reserveResource(this, priority, rmContainer);
 }
}

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

createContainer(node, perAllocationResource,
   schedulerKey);
getMetrics().reserveResource(node.getPartition(), getUser(),
  reservedContainer.getResource());
RMContainer rmContainer =

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

reservations.put(node.getNodeID(), container2);
app.reservedContainers.put(prio1, reservations);
oldMetrics.reserveResource(user, reservedResource);

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

reservations.put(node.getNodeID(), container2);
app.reservedContainers.put(toSchedulerKey(prio1), reservations);
oldMetrics.reserveResource(container2.getNodeLabelExpression(),
  user, reservedResource);

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

metrics.reserveResource(RMNodeLabelsManager.NO_LABEL,
  user, Resources.createResource(3*GB, 3));

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

metrics.reserveResource(user, Resources.createResource(3*GB, 3));