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

QueueMetrics.getAppsCompleted介绍

暂无

代码示例

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

private void resetQueueMetrics(QueueMetrics qm) {
 appsSubmittedCarryOn = qm.getAppsSubmitted();
 appsPendingCarryOn = qm.getAppsPending();
 appsRunningCarryOn = qm.getAppsRunning();
 appsCompletedCarryOn = qm.getAppsCompleted();
}

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

private void resetQueueMetrics(QueueMetrics qm) {
 appsSubmittedCarryOn = qm.getAppsSubmitted();
 appsPendingCarryOn = qm.getAppsPending();
 appsRunningCarryOn = qm.getAppsRunning();
 appsCompletedCarryOn = qm.getAppsCompleted();
}

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

private void assertQueueMetrics(QueueMetrics qm, int appsSubmitted,
  int appsPending, int appsRunning, int appsCompleted) {
 Assert.assertEquals(appsSubmitted + appsSubmittedCarryOn,
   qm.getAppsSubmitted());
 Assert.assertEquals(appsPending + appsPendingCarryOn,
   qm.getAppsPending());
 Assert.assertEquals(appsRunning + appsRunningCarryOn,
   qm.getAppsRunning());
 Assert.assertEquals(appsCompleted + appsCompletedCarryOn,
   qm.getAppsCompleted());
}

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

private void assertQueueMetrics(QueueMetrics qm, int appsSubmitted,
  int appsPending, int appsRunning, int appsCompleted) {
 Assert.assertEquals(qm.getAppsSubmitted(),
   appsSubmitted + appsSubmittedCarryOn);
 Assert.assertEquals(qm.getAppsPending(),
   appsPending + appsPendingCarryOn);
 Assert.assertEquals(qm.getAppsRunning(),
   appsRunning + appsRunningCarryOn);
 Assert.assertEquals(qm.getAppsCompleted(),
   appsCompleted + appsCompletedCarryOn);
}

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

public UserMetricsInfo(final ResourceManager rm, final String user) {
 ResourceScheduler rs = rm.getResourceScheduler();
 QueueMetrics metrics = rs.getRootQueueMetrics();
 QueueMetrics userMetrics = metrics.getUserMetrics(user);
 this.userMetricsAvailable = false;
 if (userMetrics != null) {
  this.userMetricsAvailable = true;
  this.appsSubmitted = userMetrics.getAppsSubmitted();
  this.appsCompleted = userMetrics.getAppsCompleted();
  this.appsPending = userMetrics.getAppsPending();
  this.appsRunning = userMetrics.getAppsRunning();
  this.appsFailed = userMetrics.getAppsFailed();
  this.appsKilled = userMetrics.getAppsKilled();
  this.runningContainers = userMetrics.getAllocatedContainers();
  this.pendingContainers = userMetrics.getPendingContainers();
  this.reservedContainers = userMetrics.getReservedContainers();
  this.reservedMB = userMetrics.getReservedMB();
  this.pendingMB = userMetrics.getPendingMB();
  this.allocatedMB = userMetrics.getAllocatedMB();
  this.reservedVirtualCores = userMetrics.getReservedVirtualCores();
  this.pendingVirtualCores = userMetrics.getPendingVirtualCores();
  this.allocatedVirtualCores = userMetrics.getAllocatedVirtualCores();
 }
}

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

public UserMetricsInfo(final ResourceManager rm, final String user) {
 ResourceScheduler rs = rm.getResourceScheduler();
 QueueMetrics metrics = rs.getRootQueueMetrics();
 QueueMetrics userMetrics = metrics.getUserMetrics(user);
 this.userMetricsAvailable = false;
 if (userMetrics != null) {
  this.userMetricsAvailable = true;
  this.appsSubmitted = userMetrics.getAppsSubmitted();
  this.appsCompleted = userMetrics.getAppsCompleted();
  this.appsPending = userMetrics.getAppsPending();
  this.appsRunning = userMetrics.getAppsRunning();
  this.appsFailed = userMetrics.getAppsFailed();
  this.appsKilled = userMetrics.getAppsKilled();
  this.runningContainers = userMetrics.getAllocatedContainers();
  this.pendingContainers = userMetrics.getPendingContainers();
  this.reservedContainers = userMetrics.getReservedContainers();
  this.reservedMB = userMetrics.getReservedMB();
  this.pendingMB = userMetrics.getPendingMB();
  this.allocatedMB = userMetrics.getAllocatedMB();
  this.reservedVirtualCores = userMetrics.getReservedVirtualCores();
  this.pendingVirtualCores = userMetrics.getPendingVirtualCores();
  this.allocatedVirtualCores = userMetrics.getAllocatedVirtualCores();
 }
}

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

public UserMetricsInfo(final ResourceManager rm, final String user) {
 ResourceScheduler rs = rm.getResourceScheduler();
 QueueMetrics metrics = rs.getRootQueueMetrics();
 QueueMetrics userMetrics = metrics.getUserMetrics(user);
 this.userMetricsAvailable = false;
 if (userMetrics != null) {
  this.userMetricsAvailable = true;
  this.appsSubmitted = userMetrics.getAppsSubmitted();
  this.appsCompleted = userMetrics.getAppsCompleted();
  this.appsPending = userMetrics.getAppsPending();
  this.appsRunning = userMetrics.getAppsRunning();
  this.appsFailed = userMetrics.getAppsFailed();
  this.appsKilled = userMetrics.getAppsKilled();
  this.runningContainers = userMetrics.getAllocatedContainers();
  this.pendingContainers = userMetrics.getPendingContainers();
  this.reservedContainers = userMetrics.getReservedContainers();
  this.reservedMB = userMetrics.getReservedMB();
  this.pendingMB = userMetrics.getPendingMB();
  this.allocatedMB = userMetrics.getAllocatedMB();
  this.reservedVirtualCores = userMetrics.getReservedVirtualCores();
  this.pendingVirtualCores = userMetrics.getPendingVirtualCores();
  this.allocatedVirtualCores = userMetrics.getAllocatedVirtualCores();
 }
}

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

public ClusterMetricsInfo(final ResourceManager rm) {
 ResourceScheduler rs = rm.getResourceScheduler();
 QueueMetrics metrics = rs.getRootQueueMetrics();
 ClusterMetrics clusterMetrics = ClusterMetrics.getMetrics();
 this.appsSubmitted = metrics.getAppsSubmitted();
 this.appsCompleted = metrics.getAppsCompleted();
 this.appsPending = metrics.getAppsPending();
 this.appsRunning = metrics.getAppsRunning();
 this.appsFailed = metrics.getAppsFailed();
 this.appsKilled = metrics.getAppsKilled();
 this.reservedMB = metrics.getReservedMB();
 this.availableMB = metrics.getAvailableMB();
 this.allocatedMB = metrics.getAllocatedMB();
 this.reservedVirtualCores = metrics.getReservedVirtualCores();
 this.availableVirtualCores = metrics.getAvailableVirtualCores();
 this.allocatedVirtualCores = metrics.getAllocatedVirtualCores();
 this.containersAllocated = metrics.getAllocatedContainers();
 this.containersPending = metrics.getPendingContainers();
 this.containersReserved = metrics.getReservedContainers();
 this.totalMB = availableMB + allocatedMB;
 this.totalVirtualCores = availableVirtualCores + allocatedVirtualCores;
 this.activeNodes = clusterMetrics.getNumActiveNMs();
 this.lostNodes = clusterMetrics.getNumLostNMs();
 this.unhealthyNodes = clusterMetrics.getUnhealthyNMs();
 this.decommissionedNodes = clusterMetrics.getNumDecommisionedNMs();
 this.rebootedNodes = clusterMetrics.getNumRebootedNMs();
 this.totalNodes = activeNodes + lostNodes + decommissionedNodes
   + rebootedNodes + unhealthyNodes;
}

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

this.appsCompleted = metrics.getAppsCompleted();
this.appsPending = metrics.getAppsPending();
this.appsRunning = metrics.getAppsRunning();

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

private void assertMetrics(QueueMetrics qm, int appsSubmitted,
  int appsPending, int appsRunning, int appsCompleted,
  int allocatedContainers, long availableMB, long availableVirtualCores,
  long allocatedMB, long allocatedVirtualCores) {
 assertEquals(appsSubmitted, qm.getAppsSubmitted());
 assertEquals(appsPending, qm.getAppsPending());
 assertEquals(appsRunning, qm.getAppsRunning());
 assertEquals(appsCompleted, qm.getAppsCompleted());
 assertEquals(allocatedContainers, qm.getAllocatedContainers());
 assertEquals(availableMB, qm.getAvailableMB());
 assertEquals(availableVirtualCores, qm.getAvailableVirtualCores());
 assertEquals(allocatedMB, qm.getAllocatedMB());
 assertEquals(allocatedVirtualCores, qm.getAllocatedVirtualCores());
}

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

private void assertMetrics(QueueMetrics qm, int appsSubmitted,
  int appsPending, int appsRunning, int appsCompleted,
  int allocatedContainers, int availableMB, int availableVirtualCores,
  int allocatedMB, int allocatedVirtualCores) {
 assertEquals(appsSubmitted, qm.getAppsSubmitted());
 assertEquals(appsPending, qm.getAppsPending());
 assertEquals(appsRunning, qm.getAppsRunning());
 assertEquals(appsCompleted, qm.getAppsCompleted());
 assertEquals(allocatedContainers, qm.getAllocatedContainers());
 assertEquals(availableMB, qm.getAvailableMB());
 assertEquals(availableVirtualCores, qm.getAvailableVirtualCores());
 assertEquals(allocatedMB, qm.getAllocatedMB());
 assertEquals(allocatedVirtualCores, qm.getAllocatedVirtualCores());
}

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

this.appsCompleted = metrics.getAppsCompleted();
this.appsPending = metrics.getAppsPending();
this.appsRunning = metrics.getAppsRunning();

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

assertEquals(0, a.getMetrics().getAppsPending());
assertEquals(0, a.getMetrics().getAppsFailed());
assertEquals(1, a.getMetrics().getAppsCompleted());

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

metrics.getAppsSubmitted(), submittedApps);
assertEquals("appsCompleted doesn't match", 
  metrics.getAppsCompleted(), completedApps);
assertEquals("reservedMB doesn't match",
  metrics.getReservedMB(), reservedMB);

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

metrics.getAppsSubmitted(), submittedApps);
assertEquals("appsCompleted doesn't match",
  metrics.getAppsCompleted(), completedApps);
assertEquals("reservedMB doesn't match",
  metrics.getReservedMB(), reservedMB);