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

YarnScheduler.getNodeReport介绍

[英]Get node resource usage report.
[中]获取节点资源使用情况报告。

代码示例

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

private void handleNodeUpdates(RMApp app, AllocateResponse allocateResponse) {
 Map<RMNode, NodeUpdateType> updatedNodes = new HashMap<>();
 if(app.pullRMNodeUpdates(updatedNodes) > 0) {
  List<NodeReport> updatedNodeReports = new ArrayList<>();
  for(Map.Entry<RMNode, NodeUpdateType> rmNodeEntry :
    updatedNodes.entrySet()) {
   RMNode rmNode = rmNodeEntry.getKey();
   SchedulerNodeReport schedulerNodeReport =
     getScheduler().getNodeReport(rmNode.getNodeID());
   Resource used = BuilderUtils.newResource(0, 0);
   int numContainers = 0;
   if (schedulerNodeReport != null) {
    used = schedulerNodeReport.getUsedResource();
    numContainers = schedulerNodeReport.getNumContainers();
   }
   NodeId nodeId = rmNode.getNodeID();
   NodeReport report =
     BuilderUtils.newNodeReport(nodeId, rmNode.getState(),
       rmNode.getHttpAddress(), rmNode.getRackName(), used,
       rmNode.getTotalCapability(), numContainers,
       rmNode.getHealthReport(), rmNode.getLastHealthReportTime(),
       rmNode.getNodeLabels(), rmNode.getDecommissioningTimeout(),
       rmNodeEntry.getValue());
   updatedNodeReports.add(report);
  }
  allocateResponse.setUpdatedNodes(updatedNodeReports);
 }
}

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

private NodeReport createNodeReports(RMNode rmNode) {    
 SchedulerNodeReport schedulerNodeReport = 
   scheduler.getNodeReport(rmNode.getNodeID());
 Resource used = BuilderUtils.newResource(0, 0);
 int numContainers = 0;
 if (schedulerNodeReport != null) {
  used = schedulerNodeReport.getUsedResource();
  numContainers = schedulerNodeReport.getNumContainers();
 } 
 
 NodeReport report =
   BuilderUtils.newNodeReport(rmNode.getNodeID(), rmNode.getState(),
     rmNode.getHttpAddress(), rmNode.getRackName(), used,
     rmNode.getTotalCapability(), numContainers,
     rmNode.getHealthReport(), rmNode.getLastHealthReportTime(),
     rmNode.getNodeLabels());
 return report;
}

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

private NodeReport createNodeReports(RMNode rmNode) {    
 SchedulerNodeReport schedulerNodeReport = 
   scheduler.getNodeReport(rmNode.getNodeID());
 Resource used = BuilderUtils.newResource(0, 0);
 int numContainers = 0;
 if (schedulerNodeReport != null) {
  used = schedulerNodeReport.getUsedResource();
  numContainers = schedulerNodeReport.getNumContainers();
 } 
 
 NodeReport report =
   BuilderUtils.newNodeReport(rmNode.getNodeID(), rmNode.getState(),
     rmNode.getHttpAddress(), rmNode.getRackName(), used,
     rmNode.getTotalCapability(), numContainers,
     rmNode.getHealthReport(), rmNode.getLastHealthReportTime(),
     rmNode.getNodeLabels());
 return report;
}

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

private NodeReport createNodeReports(RMNode rmNode) {
 SchedulerNodeReport schedulerNodeReport = 
   scheduler.getNodeReport(rmNode.getNodeID());
 Resource used = BuilderUtils.newResource(0, 0);
 int numContainers = 0;
 if (schedulerNodeReport != null) {
  used = schedulerNodeReport.getUsedResource();
  numContainers = schedulerNodeReport.getNumContainers();
 }
 Set<NodeAttribute> attrs = rmNode.getAllNodeAttributes();
 NodeReport report =
   BuilderUtils.newNodeReport(rmNode.getNodeID(), rmNode.getState(),
     rmNode.getHttpAddress(), rmNode.getRackName(), used,
     rmNode.getTotalCapability(), numContainers,
     rmNode.getHealthReport(), rmNode.getLastHealthReportTime(),
     rmNode.getNodeLabels(), rmNode.getAggregatedContainersUtilization(),
     rmNode.getNodeUtilization(), rmNode.getDecommissioningTimeout(),
     null, attrs);
 return report;
}

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

for(RMNode rmNode: updatedNodes) {
 SchedulerNodeReport schedulerNodeReport =  
   rScheduler.getNodeReport(rmNode.getNodeID());
 Resource used = BuilderUtils.newResource(0, 0);
 int numContainers = 0;

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

for(RMNode rmNode: updatedNodes) {
 SchedulerNodeReport schedulerNodeReport =  
   rScheduler.getNodeReport(rmNode.getNodeID());
 Resource used = BuilderUtils.newResource(0, 0);
 int numContainers = 0;