import org.apache.hadoop.yarn.server.applicationhistoryservice.records.ContainerHistoryData; //导入依赖的package包/类
private ContainerReport convertToContainerReport(
    ContainerHistoryData containerHistory, String user) {
  // If the container has the aggregated log, add the server root url
  String logUrl = WebAppUtils.getAggregatedLogURL(
      serverHttpAddress,
      containerHistory.getAssignedNode().toString(),
      containerHistory.getContainerId().toString(),
      containerHistory.getContainerId().toString(),
      user);
  return ContainerReport.newInstance(containerHistory.getContainerId(),
    containerHistory.getAllocatedResource(),
    containerHistory.getAssignedNode(), containerHistory.getPriority(),
    containerHistory.getStartTime(), containerHistory.getFinishTime(),
    containerHistory.getDiagnosticsInfo(), logUrl,
    containerHistory.getContainerExitStatus(),
    containerHistory.getContainerState(), null);
}
 

import org.apache.hadoop.yarn.server.applicationhistoryservice.records.ContainerHistoryData; //导入依赖的package包/类
@Override
public Map<ContainerId, ContainerReport> getContainers(
    ApplicationAttemptId appAttemptId) throws IOException {
  ApplicationReport app =
      getApplication(appAttemptId.getApplicationId());
  Map<ContainerId, ContainerHistoryData> histData =
      historyStore.getContainers(appAttemptId);
  HashMap<ContainerId, ContainerReport> containersReport =
      new HashMap<ContainerId, ContainerReport>();
  for (Entry<ContainerId, ContainerHistoryData> entry : histData.entrySet()) {
    containersReport.put(entry.getKey(),
      convertToContainerReport(entry.getValue(),
          app == null ? null : app.getUser()));
  }
  return containersReport;
}
 

import org.apache.hadoop.yarn.server.applicationhistoryservice.records.ContainerHistoryData; //导入依赖的package包/类
@Override
public void containerStarted(ContainerStartData containerStart)
    throws IOException {
  ConcurrentMap<ContainerId, ContainerHistoryData> subMap =
      getSubMap(containerStart.getContainerId().getApplicationAttemptId());
  ContainerHistoryData oldData =
      subMap.putIfAbsent(containerStart.getContainerId(),
        ContainerHistoryData.newInstance(containerStart.getContainerId(),
          containerStart.getAllocatedResource(),
          containerStart.getAssignedNode(), containerStart.getPriority(),
          containerStart.getStartTime(), Long.MAX_VALUE, null,
          Integer.MAX_VALUE, null));
  if (oldData != null) {
    throw new IOException("The start information of container "
        + containerStart.getContainerId() + " is already stored.");
  }
}
 

import org.apache.hadoop.yarn.server.applicationhistoryservice.records.ContainerHistoryData; //导入依赖的package包/类
@Override
public void containerFinished(ContainerFinishData containerFinish)
    throws IOException {
  ConcurrentMap<ContainerId, ContainerHistoryData> subMap =
      getSubMap(containerFinish.getContainerId().getApplicationAttemptId());
  ContainerHistoryData data = subMap.get(containerFinish.getContainerId());
  if (data == null) {
    throw new IOException("The finish information of container "
        + containerFinish.getContainerId() + " is stored before"
        + " the start information.");
  }
  // Make the assumption that ContainerState should not be null if
  // the finish information is already recorded
  if (data.getContainerState() != null) {
    throw new IOException("The finish information of container "
        + containerFinish.getContainerId() + " is already stored.");
  }
  data.setFinishTime(containerFinish.getFinishTime());
  data.setDiagnosticsInfo(containerFinish.getDiagnosticsInfo());
  data.setContainerExitStatus(containerFinish.getContainerExitStatus());
  data.setContainerState(containerFinish.getContainerState());
}
 

import org.apache.hadoop.yarn.server.applicationhistoryservice.records.ContainerHistoryData; //导入依赖的package包/类
private ContainerReport convertToContainerReport(
    ContainerHistoryData containerHistory, String user) {
  // If the container has the aggregated log, add the server root url
  String logUrl = WebAppUtils.getAggregatedLogURL(
      serverHttpAddress,
      containerHistory.getAssignedNode().toString(),
      containerHistory.getContainerId().toString(),
      containerHistory.getContainerId().toString(),
      user);
  return ContainerReport.newInstance(containerHistory.getContainerId(),
    containerHistory.getAllocatedResource(),
    containerHistory.getAssignedNode(), containerHistory.getPriority(),
    containerHistory.getStartTime(), containerHistory.getFinishTime(),
    containerHistory.getDiagnosticsInfo(), logUrl,
    containerHistory.getContainerExitStatus(),
    containerHistory.getContainerState());
}
 

import org.apache.hadoop.yarn.server.applicationhistoryservice.records.ContainerHistoryData; //导入依赖的package包/类
@Override
public ContainerHistoryData getAMContainer(ApplicationAttemptId appAttemptId) {
  ApplicationAttemptHistoryData appAttempt =
      getApplicationAttempt(appAttemptId);
  if (appAttempt == null || appAttempt.getMasterContainerId() == null) {
    return null;
  } else {
    return getContainer(appAttempt.getMasterContainerId());
  }
}
 

import org.apache.hadoop.yarn.server.applicationhistoryservice.records.ContainerHistoryData; //导入依赖的package包/类
@Override
public ContainerHistoryData getContainer(ContainerId containerId) {
  Map<ContainerId, ContainerHistoryData> subMap =
      containerData.get(containerId.getApplicationAttemptId());
  if (subMap == null) {
    return null;
  } else {
    return subMap.get(containerId);
  }
}
 

import org.apache.hadoop.yarn.server.applicationhistoryservice.records.ContainerHistoryData; //导入依赖的package包/类
@Override
public Map<ContainerId, ContainerHistoryData> getContainers(
    ApplicationAttemptId appAttemptId) throws IOException {
  ConcurrentMap<ContainerId, ContainerHistoryData> subMap =
      containerData.get(appAttemptId);
  if (subMap == null) {
    return Collections.<ContainerId, ContainerHistoryData> emptyMap();
  } else {
    return new HashMap<ContainerId, ContainerHistoryData>(subMap);
  }
}
 

import org.apache.hadoop.yarn.server.applicationhistoryservice.records.ContainerHistoryData; //导入依赖的package包/类
@Override
public ContainerHistoryData getAMContainer(ApplicationAttemptId appAttemptId)
    throws IOException {
  ApplicationAttemptHistoryData attemptHistoryData =
      getApplicationAttempt(appAttemptId);
  if (attemptHistoryData == null
      || attemptHistoryData.getMasterContainerId() == null) {
    return null;
  }
  return getContainer(attemptHistoryData.getMasterContainerId());
}
 

import org.apache.hadoop.yarn.server.applicationhistoryservice.records.ContainerHistoryData; //导入依赖的package包/类
private static void mergeContainerHistoryData(
    ContainerHistoryData historyData, ContainerStartData startData) {
  historyData.setAllocatedResource(startData.getAllocatedResource());
  historyData.setAssignedNode(startData.getAssignedNode());
  historyData.setPriority(startData.getPriority());
  historyData.setStartTime(startData.getStartTime());
}