import org.apache.hadoop.yarn.server.utils.YarnServerBuilderUtils; //导入依赖的package包/类
@Override
public NodeHeartbeatResponse nodeHeartbeat(NodeHeartbeatRequest request)
    throws YarnException, IOException {
  System.out.println("RTS receive heartbeat : "
      + System.currentTimeMillis());
  labels = request.getNodeLabels();
  NodeStatus nodeStatus = request.getNodeStatus();
  nodeStatus.setResponseId(heartbeatID++);

  NodeHeartbeatResponse nhResponse =
      YarnServerBuilderUtils.newNodeHeartbeatResponse(heartbeatID,
          NodeAction.NORMAL, null, null, null, null, 1000L);

  // to ensure that heartbeats are sent only when required.
  nhResponse.setNextHeartBeatInterval(Long.MAX_VALUE);
  nhResponse.setAreNodeLabelsAcceptedByRM(labels != null);

  synchronized (ResourceTrackerForLabels.class) {
    receivedNMHeartbeat = true;
    ResourceTrackerForLabels.class.notifyAll();
  }
  return nhResponse;
}
 

import org.apache.hadoop.yarn.server.utils.YarnServerBuilderUtils; //导入依赖的package包/类
@Override
public LiveRMsResponse getLiveRMList() {

  List<ActiveNode> rmList = new ArrayList<ActiveNode>();
  Map<String, Load> loads;
  try {
    loads = DBUtility.getAllLoads();
  } catch (IOException ex) {
    LOG.error(ex);
    loads = new HashMap<String, Load>();
  }
  SortedActiveNodeList nnList = groupMembership.getActiveNamenodes();
  for (ActiveNode node : nnList.getSortedActiveNodes()) {
    if (loads.get(node.getHostname()) == null) {
      rmList.add(new ActiveRMPBImpl(node.getId(), node.getHostname(), node.
              getRpcServerIpAddress(), node.getRpcServerPort(), node.getHttpAddress(), 0));
    } else {
      rmList.add(new ActiveRMPBImpl(node.getId(), node.getHostname(), node.
              getRpcServerIpAddress(), node.getRpcServerPort(), node.getHttpAddress(), loads.
          get(node.getHostname()).getLoad()));
    }
  }
  SortedActiveRMList sortedRmList = new SortedActiveRMList(rmList);
  return YarnServerBuilderUtils.newLiveRMsResponse(sortedRmList);

}
 

import org.apache.hadoop.yarn.server.utils.YarnServerBuilderUtils; //导入依赖的package包/类
@Override
public NodeHeartbeatResponse nodeHeartbeat(NodeHeartbeatRequest request)
    throws YarnException, IOException {
  NodeStatus nodeStatus = request.getNodeStatus();
  nodeStatus.setResponseId(heartBeatID++);

  NodeHeartbeatResponse nhResponse = YarnServerBuilderUtils.
      newNodeHeartbeatResponse(heartBeatID, heartBeatNodeAction, null,
          null, null, null, 1000L);
  nhResponse.setDiagnosticsMessage(shutDownMessage);
  return nhResponse;
}
 

import org.apache.hadoop.yarn.server.utils.YarnServerBuilderUtils; //导入依赖的package包/类
@Override
public NodeHeartbeatResponse nodeHeartbeat(NodeHeartbeatRequest request)
    throws YarnException, IOException {
  NodeStatus nodeStatus = request.getNodeStatus();
  LOG.info("Got heartbeat number " + heartBeatID);
  nodeStatus.setResponseId(heartBeatID++);

  NodeHeartbeatResponse nhResponse = YarnServerBuilderUtils
      .newNodeHeartbeatResponse(heartBeatID, null, null,
          null, null, null, 1000L);
  return nhResponse;
}
 

import org.apache.hadoop.yarn.server.utils.YarnServerBuilderUtils; //导入依赖的package包/类
@Override
public NodeHeartbeatResponse nodeHeartbeat(NodeHeartbeatRequest request)
    throws YarnException, IOException {
  NodeStatus nodeStatus = request.getNodeStatus();
  nodeStatus.setResponseId(heartBeatID++);

  NodeHeartbeatResponse nhResponse = YarnServerBuilderUtils.
      newNodeHeartbeatResponse(heartBeatID, heartBeatNodeAction, null,
          null, null, null, null, 1000L);
  nhResponse.setDiagnosticsMessage(shutDownMessage);
  return nhResponse;
}
 

import org.apache.hadoop.yarn.server.utils.YarnServerBuilderUtils; //导入依赖的package包/类
@Override
public NodeHeartbeatResponse nodeHeartbeat(NodeHeartbeatRequest request)
    throws YarnException, IOException {
  NodeStatus nodeStatus = request.getNodeStatus();
  LOG.info("Got heartbeat number " + heartBeatID);
  nodeStatus.setResponseId(heartBeatID++);

  NodeHeartbeatResponse nhResponse = YarnServerBuilderUtils
      .newNodeHeartbeatResponse(heartBeatID, null, null,
          null, null, null, null, 1000L);
  return nhResponse;
}
 

import org.apache.hadoop.yarn.server.utils.YarnServerBuilderUtils; //导入依赖的package包/类
@Override
public NodeHeartbeatResponse nodeHeartbeat(NodeHeartbeatRequest request)
    throws YarnException, IOException {
  NodeStatus nodeStatus = request.getNodeStatus();
  nodeStatus.setResponseId(heartBeatID++);
  
  NodeHeartbeatResponse nhResponse = YarnServerBuilderUtils.
      newNodeHeartbeatResponse(heartBeatID, heartBeatNodeAction, null,
          null, null, null, 1000L);
  nhResponse.setDiagnosticsMessage(shutDownMessage);
  return nhResponse;
}