import org.apache.hadoop.yarn.sls.utils.SLSUtils; //导入依赖的package包/类
public void init(String nodeIdStr, int memory, int cores,
        int dispatchTime, int heartBeatInterval, ResourceManager rm)
        throws IOException, YarnException {
  super.init(dispatchTime, dispatchTime + 1000000L * heartBeatInterval,
          heartBeatInterval);
  // create resource
  String rackHostName[] = SLSUtils.getRackHostName(nodeIdStr);
  this.node = NodeInfo.newNodeInfo(rackHostName[0], rackHostName[1], 
                BuilderUtils.newResource(memory, cores));
  this.rm = rm;
  // init data structures
  completedContainerList =
          Collections.synchronizedList(new ArrayList<ContainerId>());
  releasedContainerList =
          Collections.synchronizedList(new ArrayList<ContainerId>());
  containerQueue = new DelayQueue<ContainerSimulator>();
  amContainerList =
          Collections.synchronizedList(new ArrayList<ContainerId>());
  runningContainers =
          new ConcurrentHashMap<ContainerId, ContainerSimulator>();
  // register NM with RM
  RegisterNodeManagerRequest req =
          Records.newRecord(RegisterNodeManagerRequest.class);
  req.setNodeId(node.getNodeID());
  req.setResource(node.getTotalCapability());
  req.setHttpPort(80);
  RegisterNodeManagerResponse response = rm.getResourceTrackerService()
          .registerNodeManager(req);
  masterKey = response.getNMTokenMasterKey();
}
 

import org.apache.hadoop.yarn.sls.utils.SLSUtils; //导入依赖的package包/类
@SuppressWarnings("unchecked")
private static List createSLSTasks(String taskType,
                                   List rumenTasks, long offset) {
  int priority = taskType.equals("reduce") ? 10 : 20;
  List array = new ArrayList();
  for (Object e : rumenTasks) {
    Map rumenTask = (Map) e;
    for (Object ee : (List) rumenTask.get("attempts"))  {
      Map rumenAttempt = (Map) ee;
      long taskStart = (Long) rumenAttempt.get("startTime");
      long taskFinish = (Long) rumenAttempt.get("finishTime");
      String hostname = (String) rumenAttempt.get("hostName");
      taskStart = taskStart - baseline + offset;
      taskFinish = taskFinish - baseline + offset;
      Map task = new LinkedHashMap();
      task.put("container.host", hostname);
      task.put("container.start.ms", taskStart);
      task.put("container.end.ms", taskFinish);
      task.put("container.priority", priority);
      task.put("container.type", taskType);
      array.add(task);
      String rackHost[] = SLSUtils.getRackHostName(hostname);
      if (rackNodeMap.containsKey(rackHost[0])) {
        rackNodeMap.get(rackHost[0]).add(rackHost[1]);
      } else {
        Set<String> hosts = new TreeSet<String>();
        hosts.add(rackHost[1]);
        rackNodeMap.put(rackHost[0], hosts);
      }
    }
  }
  return array;
}