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

Queue.getMetrics介绍

[英]Get the queue metrics
[中]获取队列度量

代码示例

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

/**
 * Get metrics reference from containing queue.
 */
public QueueMetrics getMetrics() {
 return queue.getMetrics();
}

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

/**
 * Get metrics reference from containing queue.
 */
public QueueMetrics getMetrics() {
 return queue.getMetrics();
}

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

/**
 * Get metrics reference from containing queue.
 */
public QueueMetrics getMetrics() {
 return queue.getMetrics();
}

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

@Override
public QueueMetrics getRootQueueMetrics() {
 return DEFAULT_QUEUE.getMetrics();
}

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

@Override
public QueueMetrics getRootQueueMetrics() {
 return DEFAULT_QUEUE.getMetrics();
}

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

@Override
public QueueMetrics getRootQueueMetrics() {
 return DEFAULT_QUEUE.getMetrics();
}

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

public void recordContainerAllocationTime(long value) {
 if (firstContainerAllocatedTime.compareAndSet(0, value)) {
  long timediff = firstContainerAllocatedTime.longValue() -
    firstAllocationRequestSentTime.longValue();
  if (timediff > 0) {
   queue.getMetrics().addAppAttemptFirstContainerAllocationDelay(timediff);
  }
 }
}

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

public void stop(RMAppState rmAppFinalState) {
 queue.getMetrics().finishApp(user, rmAppFinalState);
}

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

public void stop(RMAppState rmAppFinalState) {
 queue.getMetrics().finishApp(user, rmAppFinalState);
}

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

public void stop(RMAppState rmAppFinalState) {
 queue.getMetrics().finishApp(user, rmAppFinalState);
}

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

protected QueueMetrics(MetricsSystem ms, String queueName, Queue parent, 
     boolean enableUserMetrics, Configuration conf) {
 registry = new MetricsRegistry(RECORD_INFO);
 this.queueName = queueName;
 this.parent = parent != null ? parent.getMetrics() : null;
 this.users = enableUserMetrics ? new HashMap<String, QueueMetrics>()
                 : null;
 metricsSystem = ms;
 this.conf = conf;
 runningTime = buildBuckets(conf);
}

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

protected QueueMetrics(MetricsSystem ms, String queueName, Queue parent, 
     boolean enableUserMetrics, Configuration conf) {
 registry = new MetricsRegistry(RECORD_INFO);
 this.queueName = queueName;
 this.parent = parent != null ? parent.getMetrics() : null;
 this.users = enableUserMetrics ? new HashMap<String, QueueMetrics>()
                 : null;
 metricsSystem = ms;
 this.conf = conf;
 runningTime = buildBuckets(conf);
}

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

protected QueueMetrics(MetricsSystem ms, String queueName, Queue parent, 
     boolean enableUserMetrics, Configuration conf) {
 registry = new MetricsRegistry(RECORD_INFO);
 this.queueName = queueName;
 this.parent = parent != null ? parent.getMetrics() : null;
 this.users = enableUserMetrics ? new HashMap<String, QueueMetrics>()
                 : null;
 metricsSystem = ms;
 this.conf = conf;
 runningTime = buildBuckets(conf);
}

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

private void updateMetricsForAllocatedContainer(NodeType type,
  SchedulerNode node, Container containerAllocated) {
 QueueMetrics metrics = queue.getMetrics();
 if (pending) {
  // once an allocation is done we assume the application is
  // running from scheduler's POV.
  pending = false;
  metrics.runAppAttempt(applicationId, user);
 }
 updateMetrics(applicationId, type, node, containerAllocated, user, queue);
}

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

synchronized public void stop(RMAppAttemptState rmAppAttemptFinalState) {
 // clear pending resources metrics for the application
 QueueMetrics metrics = queue.getMetrics();
 for (Map<String, ResourceRequest> asks : requests.values()) {
  ResourceRequest request = asks.get(ResourceRequest.ANY);
  if (request != null) {
   metrics.decrPendingResources(user, request.getNumContainers(),
     request.getCapability());
  }
 }
 metrics.finishAppAttempt(applicationId, pending, user);
 
 // Clear requests themselves
 clearRequests();
}

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

private Queue createQueue(String name, Queue parent) {
 QueueMetrics metrics = QueueMetrics.forQueue(name, parent, false, conf);
 ActiveUsersManager activeUsersManager = new ActiveUsersManager(metrics);
 Queue queue = mock(Queue.class);
 when(queue.getMetrics()).thenReturn(metrics);
 when(queue.getActiveUsersManager()).thenReturn(activeUsersManager);
 return queue;
}

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

private Queue createQueue(String name, Queue parent, float capacity) {
 QueueMetrics metrics = QueueMetrics.forQueue(name, parent, false, conf);
 QueueInfo queueInfo = QueueInfo.newInstance(name, capacity, 1.0f, 0, null,
   null, QueueState.RUNNING, null, "", null, false, null, false);
 ActiveUsersManager activeUsersManager = new ActiveUsersManager(metrics);
 Queue queue = mock(Queue.class);
 when(queue.getMetrics()).thenReturn(metrics);
 when(queue.getAbstractUsersManager()).thenReturn(activeUsersManager);
 when(queue.getQueueInfo(false, false)).thenReturn(queueInfo);
 return queue;
}

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

@SuppressWarnings("static-access")
public void clearQueueMetrics(RMApp app) {
 ((AbstractYarnScheduler<SchedulerApplicationAttempt, SchedulerNode>) getResourceScheduler())
  .getSchedulerApplications().get(app.getApplicationId()).getQueue()
  .getMetrics().clearQueueMetrics();
}

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

@SuppressWarnings("static-access")
public void clearQueueMetrics(RMApp app) {
 ((AbstractYarnScheduler<SchedulerApplicationAttempt, SchedulerNode>) getResourceScheduler())
  .getSchedulerApplications().get(app.getApplicationId()).getQueue()
  .getMetrics().clearQueueMetrics();
}