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

x33g5p2x  于2022-01-28 转载在 其他  
字(16.6k)|赞(0)|评价(0)|浏览(166)

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

QueueMetrics.getReservedMB介绍

暂无

代码示例

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

.getReservedMB(), getMetrics().getReservedVirtualCores()))) {
break;

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

.getReservedMB(), getMetrics().getReservedVirtualCores()))) {
break;

代码示例来源：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: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

private void checkQueueMetrics(QueueMetrics metrics, int activeApps,
  int runningApps, int allocMb, int allocVcores, int reservedMb,
  int reservedVcores, int pendingMb, int pendingVcores) {
 assertEquals(activeApps, metrics.getActiveApps());
 assertEquals(runningApps, metrics.getAppsRunning());
 assertEquals(allocMb, metrics.getAllocatedMB());
 assertEquals(allocVcores, metrics.getAllocatedVirtualCores());
 assertEquals(reservedMb, metrics.getReservedMB());
 assertEquals(reservedVcores, metrics.getReservedVirtualCores());
 assertEquals(pendingMb, metrics.getPendingMB());
 assertEquals(pendingVcores, metrics.getPendingVirtualCores());
}

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

private void checkQueueMetrics(QueueMetrics metrics, int activeApps,
  int runningApps, int allocMb, int allocVcores, int reservedMb,
  int reservedVcores, int pendingMb, int pendingVcores) {
 assertEquals(activeApps, metrics.getActiveApps());
 assertEquals(runningApps, metrics.getAppsRunning());
 assertEquals(allocMb, metrics.getAllocatedMB());
 assertEquals(allocVcores, metrics.getAllocatedVirtualCores());
 assertEquals(reservedMb, metrics.getReservedMB());
 assertEquals(reservedVcores, metrics.getReservedVirtualCores());
 assertEquals(pendingMb, metrics.getPendingMB());
 assertEquals(pendingVcores, metrics.getPendingVirtualCores());
}

代码示例来源：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.appsKilled = metrics.getAppsKilled();
this.reservedMB = metrics.getReservedMB();
this.availableMB = metrics.getAvailableMB();
this.allocatedMB = metrics.getAllocatedMB();

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

assertEquals(0, metrics.getReservedMB());
assertEquals(0, metrics.getReservedVirtualCores());
assertEquals(4096, metrics.getReservedMB());
assertEquals(4, metrics.getReservedVirtualCores());
assertEquals(0, metrics.getReservedMB());
assertEquals(0, metrics.getReservedVirtualCores());

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

assertEquals(2*GB, app_0.getCurrentConsumption().getMemory());
assertEquals(0*GB, app_1.getCurrentConsumption().getMemory());
assertEquals(0*GB, a.getMetrics().getReservedMB());
assertEquals(2*GB, a.getMetrics().getAllocatedMB());
assertEquals(0*GB, a.getMetrics().getAvailableMB());
assertEquals(4*GB, app_1.getCurrentReservation().getMemory());
assertEquals(2*GB, node_0.getUsedResource().getMemory());
assertEquals(4*GB, a.getMetrics().getReservedMB());
assertEquals(2*GB, a.getMetrics().getAllocatedMB());
assertEquals(4*GB, app_1.getCurrentReservation().getMemory());
assertEquals(4*GB, node_1.getUsedResource().getMemory());
assertEquals(4*GB, a.getMetrics().getReservedMB());
assertEquals(6*GB, a.getMetrics().getAllocatedMB());
assertEquals(0*GB, app_1.getCurrentReservation().getMemory());
assertEquals(4*GB, node_0.getUsedResource().getMemory());
assertEquals(0*GB, a.getMetrics().getReservedMB());
assertEquals(8*GB, a.getMetrics().getAllocatedMB());

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

assertEquals(2 * GB, app_0.getCurrentConsumption().getMemory());
assertEquals(0 * GB, app_1.getCurrentConsumption().getMemory());
assertEquals(0 * GB, a.getMetrics().getReservedMB());
assertEquals(2 * GB, a.getMetrics().getAllocatedMB());
assertEquals(22 * GB, a.getMetrics().getAvailableMB());
assertEquals(2 * GB, app_0.getCurrentConsumption().getMemory());
assertEquals(2 * GB, app_1.getCurrentConsumption().getMemory());
assertEquals(0 * GB, a.getMetrics().getReservedMB());
assertEquals(4 * GB, a.getMetrics().getAllocatedMB());
assertEquals(20 * GB, a.getMetrics().getAvailableMB());
assertEquals(2 * GB, app_0.getCurrentConsumption().getMemory());
assertEquals(2 * GB, app_1.getCurrentConsumption().getMemory());
assertEquals(8 * GB, a.getMetrics().getReservedMB());
assertEquals(4 * GB, a.getMetrics().getAllocatedMB());
assertEquals(12 * GB, a.getMetrics().getAvailableMB());
assertEquals(2 * GB, app_0.getCurrentConsumption().getMemory());
assertEquals(4 * GB, app_1.getCurrentConsumption().getMemory());
assertEquals(8 * GB, a.getMetrics().getReservedMB());
assertEquals(6 * GB, a.getMetrics().getAllocatedMB());
assertEquals(10 * GB, a.getMetrics().getAvailableMB());

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

assertEquals(1*GB, app_0.getCurrentConsumption().getMemory());
assertEquals(0*GB, app_1.getCurrentConsumption().getMemory());
assertEquals(0*GB, a.getMetrics().getReservedMB());
assertEquals(1*GB, a.getMetrics().getAllocatedMB());
assertEquals(0*GB, a.getMetrics().getAvailableMB());
assertEquals(2*GB, app_0.getCurrentConsumption().getMemory());
assertEquals(0*GB, app_1.getCurrentConsumption().getMemory());
assertEquals(0*GB, a.getMetrics().getReservedMB());
assertEquals(2*GB, a.getMetrics().getAllocatedMB());
assertEquals(4*GB, app_1.getCurrentReservation().getMemory());
assertEquals(2*GB, node_0.getUsedResource().getMemory());
assertEquals(4*GB, a.getMetrics().getReservedMB());
assertEquals(2*GB, a.getMetrics().getAllocatedMB());
assertEquals(4*GB, app_1.getCurrentReservation().getMemory());
assertEquals(1*GB, node_0.getUsedResource().getMemory());
assertEquals(4*GB, a.getMetrics().getReservedMB());
assertEquals(1*GB, a.getMetrics().getAllocatedMB());
assertEquals(0*GB, app_1.getCurrentReservation().getMemory());
assertEquals(4*GB, node_0.getUsedResource().getMemory());
assertEquals(0*GB, a.getMetrics().getReservedMB());
assertEquals(4*GB, a.getMetrics().getAllocatedMB());

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

this.appsKilled = metrics.getAppsKilled();
this.reservedMB = metrics.getReservedMB();
this.availableMB = metrics.getAvailableMB();
this.allocatedMB = metrics.getAllocatedMB();

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

assertEquals(2 * GB, a.getUsedResources().getMemory());
assertEquals(2 * GB, app_0.getCurrentConsumption().getMemory());
assertEquals(0 * GB, a.getMetrics().getReservedMB());
assertEquals(2 * GB, a.getMetrics().getAllocatedMB());
assertEquals(14 * GB, a.getMetrics().getAvailableMB());
assertEquals(5 * GB, a.getUsedResources().getMemory());
assertEquals(5 * GB, app_0.getCurrentConsumption().getMemory());
assertEquals(0 * GB, a.getMetrics().getReservedMB());
assertEquals(5 * GB, a.getMetrics().getAllocatedMB());
assertEquals(11 * GB, a.getMetrics().getAvailableMB());
assertEquals(8 * GB, a.getUsedResources().getMemory());
assertEquals(8 * GB, app_0.getCurrentConsumption().getMemory());
assertEquals(0 * GB, a.getMetrics().getReservedMB());
assertEquals(8 * GB, a.getMetrics().getAllocatedMB());
assertEquals(8 * GB, a.getMetrics().getAvailableMB());
assertEquals(5 * GB, app_0.getCurrentReservation().getMemory());
assertEquals(5 * GB, a.getMetrics().getReservedMB());
assertEquals(8 * GB, a.getMetrics().getAllocatedMB());
assertEquals(3 * GB, a.getMetrics().getAvailableMB());

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

assertEquals(2 * GB, a.getUsedResources().getMemory());
assertEquals(2 * GB, app_0.getCurrentConsumption().getMemory());
assertEquals(0 * GB, a.getMetrics().getReservedMB());
assertEquals(2 * GB, a.getMetrics().getAllocatedMB());
assertEquals(14 * GB, a.getMetrics().getAvailableMB());
assertEquals(5 * GB, a.getUsedResources().getMemory());
assertEquals(5 * GB, app_0.getCurrentConsumption().getMemory());
assertEquals(0 * GB, a.getMetrics().getReservedMB());
assertEquals(5 * GB, a.getMetrics().getAllocatedMB());
assertEquals(11 * GB, a.getMetrics().getAvailableMB());
assertEquals(8 * GB, a.getUsedResources().getMemory());
assertEquals(8 * GB, app_0.getCurrentConsumption().getMemory());
assertEquals(0 * GB, a.getMetrics().getReservedMB());
assertEquals(8 * GB, a.getMetrics().getAllocatedMB());
assertEquals(8 * GB, a.getMetrics().getAvailableMB());
assertEquals(13 * GB, a.getUsedResources().getMemory());
assertEquals(8 * GB, app_0.getCurrentConsumption().getMemory());
assertEquals(5 * GB, a.getMetrics().getReservedMB());
assertEquals(8 * GB, a.getMetrics().getAllocatedMB());
assertEquals(3 * GB, a.getMetrics().getAvailableMB());
assertEquals(13 * GB, a.getUsedResources().getMemory());
assertEquals(13 * GB, app_0.getCurrentConsumption().getMemory());
assertEquals(0 * GB, a.getMetrics().getReservedMB());
assertEquals(13 * GB, a.getMetrics().getAllocatedMB());
assertEquals(3 * GB, a.getMetrics().getAvailableMB());

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

assertEquals(2 * GB, a.getUsedResources().getMemory());
assertEquals(2 * GB, app_0.getCurrentConsumption().getMemory());
assertEquals(0 * GB, a.getMetrics().getReservedMB());
assertEquals(2 * GB, a.getMetrics().getAllocatedMB());
assertEquals(14 * GB, a.getMetrics().getAvailableMB());
assertEquals(5 * GB, a.getUsedResources().getMemory());
assertEquals(5 * GB, app_0.getCurrentConsumption().getMemory());
assertEquals(0 * GB, a.getMetrics().getReservedMB());
assertEquals(5 * GB, a.getMetrics().getAllocatedMB());
assertEquals(11 * GB, a.getMetrics().getAvailableMB());
assertEquals(8 * GB, a.getUsedResources().getMemory());
assertEquals(8 * GB, app_0.getCurrentConsumption().getMemory());
assertEquals(0 * GB, a.getMetrics().getReservedMB());
assertEquals(8 * GB, a.getMetrics().getAllocatedMB());
assertEquals(8 * GB, a.getMetrics().getAvailableMB());
assertEquals(13 * GB, a.getUsedResources().getMemory());
assertEquals(8 * GB, app_0.getCurrentConsumption().getMemory());
assertEquals(5 * GB, a.getMetrics().getReservedMB());
assertEquals(8 * GB, a.getMetrics().getAllocatedMB());
assertEquals(3 * GB, a.getMetrics().getAvailableMB());

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

assertEquals(2 * GB, a.getUsedResources().getMemory());
assertEquals(2 * GB, app_0.getCurrentConsumption().getMemory());
assertEquals(0 * GB, a.getMetrics().getReservedMB());
assertEquals(2 * GB, a.getMetrics().getAllocatedMB());
assertEquals(22 * GB, a.getMetrics().getAvailableMB());
assertEquals(5 * GB, a.getUsedResources().getMemory());
assertEquals(5 * GB, app_0.getCurrentConsumption().getMemory());
assertEquals(0 * GB, a.getMetrics().getReservedMB());
assertEquals(5 * GB, a.getMetrics().getAllocatedMB());
assertEquals(19 * GB, a.getMetrics().getAvailableMB());
assertEquals(8 * GB, a.getUsedResources().getMemory());
assertEquals(8 * GB, app_0.getCurrentConsumption().getMemory());
assertEquals(0 * GB, a.getMetrics().getReservedMB());
assertEquals(8 * GB, a.getMetrics().getAllocatedMB());
assertEquals(16 * GB, a.getMetrics().getAvailableMB());
assertEquals(8 * GB, a.getUsedResources().getMemory());
assertEquals(8 * GB, app_0.getCurrentConsumption().getMemory());
assertEquals(0 * GB, a.getMetrics().getReservedMB());
assertEquals(8 * GB, a.getMetrics().getAllocatedMB());
assertEquals(16 * GB, a.getMetrics().getAvailableMB());
assertEquals(8 * GB, a.getUsedResources().getMemory());
assertEquals(8 * GB, app_0.getCurrentConsumption().getMemory());
assertEquals(0 * GB, a.getMetrics().getReservedMB());
assertEquals(8 * GB, a.getMetrics().getAllocatedMB());
assertEquals(16 * GB, a.getMetrics().getAvailableMB());

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

metrics.getAppsCompleted(), completedApps);
assertEquals("reservedMB doesn't match",
  metrics.getReservedMB(), reservedMB);
assertEquals("availableMB doesn't match", 
  metrics.getAvailableMB(), availableMB);

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

metrics.getAppsCompleted(), completedApps);
assertEquals("reservedMB doesn't match",
  metrics.getReservedMB(), reservedMB);
assertEquals("availableMB doesn't match",
  metrics.getAvailableMB(), availableMB);

内容来源于网络，如有侵权，请联系作者删除！

QueueMetrics

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    QueueMetrics类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com