import org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalizerAction; //导入依赖的package包/类
public LocalizerHeartbeatResponse processHeartbeat(LocalizerStatus status) {
  String locId = status.getLocalizerId();
  synchronized (privLocalizers) {
    LocalizerRunner localizer = privLocalizers.get(locId);
    if (null == localizer) {
      // TODO process resources anyway
      LOG.info("Unknown localizer with localizerId " + locId
          + " is sending heartbeat. Ordering it to DIE");
      LocalizerHeartbeatResponse response =
        recordFactory.newRecordInstance(LocalizerHeartbeatResponse.class);
      response.setLocalizerAction(LocalizerAction.DIE);
      return response;
    }
    return localizer.processHeartbeat(status.getResources());
  }
}
 

import org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalizerAction; //导入依赖的package包/类
static LocalizerHeartbeatResponse createLocalizerHeartbeatResponse() 
    throws URISyntaxException {
  LocalizerHeartbeatResponse ret =
    recordFactory.newRecordInstance(LocalizerHeartbeatResponse.class);
  assertTrue(ret instanceof LocalizerHeartbeatResponsePBImpl);
  ret.setLocalizerAction(LocalizerAction.LIVE);
  LocalResource rsrc = createResource();
  ArrayList<ResourceLocalizationSpec> rsrcs =
    new ArrayList<ResourceLocalizationSpec>();
  ResourceLocalizationSpec resource =
    recordFactory.newRecordInstance(ResourceLocalizationSpec.class);
  resource.setResource(rsrc);
  resource.setDestinationDirectory(ConverterUtils
    .getYarnUrlFromPath(new Path("/tmp" + System.currentTimeMillis())));
  rsrcs.add(resource);
  ret.setResourceSpecs(rsrcs);
  System.out.println(resource);
  return ret;
}
 

import org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalizerAction; //导入依赖的package包/类
public LocalizerHeartbeatResponse processHeartbeat(LocalizerStatus status) {
  String locId = status.getLocalizerId();
  synchronized (privLocalizers) {
    LocalizerRunner localizer = privLocalizers.get(locId);
    if (null == localizer) {
      // TODO process resources anyway
      LOG.info("Unknown localizer with localizerId " + locId
          + " is sending heartbeat. Ordering it to DIE");
      LocalizerHeartbeatResponse response =
        recordFactory.newRecordInstance(LocalizerHeartbeatResponse.class);
      response.setLocalizerAction(LocalizerAction.DIE);
      return response;
    }
    return localizer.update(status.getResources());
  }
}
 

import org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalizerAction; //导入依赖的package包/类
static LocalizerHeartbeatResponse createLocalizerHeartbeatResponse() 
    throws URISyntaxException {
  LocalizerHeartbeatResponse ret =
    recordFactory.newRecordInstance(LocalizerHeartbeatResponse.class);
  assertTrue(ret instanceof LocalizerHeartbeatResponsePBImpl);
  ret.setLocalizerAction(LocalizerAction.LIVE);
  LocalResource rsrc = createResource();
  ArrayList<ResourceLocalizationSpec> rsrcs =
    new ArrayList<ResourceLocalizationSpec>();
  ResourceLocalizationSpec resource =
    recordFactory.newRecordInstance(ResourceLocalizationSpec.class);
  resource.setResource(rsrc);
  resource.setDestinationDirectory(
      URL.fromPath((new Path("/tmp" + System.currentTimeMillis()))));
  rsrcs.add(resource);
  ret.setResourceSpecs(rsrcs);
  System.out.println(resource);
  return ret;
}
 

import org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalizerAction; //导入依赖的package包/类
@Override
public LocalizerAction getLocalizerAction() {
  LocalizerHeartbeatResponseProtoOrBuilder p = viaProto ? proto : builder;
  if (!p.hasAction()) {
    return null;
  }
  return convertFromProtoFormat(p.getAction());
}
 

import org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalizerAction; //导入依赖的package包/类
public void setLocalizerAction(LocalizerAction action) {
  maybeInitBuilder();
  if (action == null) {
    builder.clearAction();
    return;
  }
  builder.setAction(convertToProtoFormat(action));
}
 

import org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalizerAction; //导入依赖的package包/类
private LocalizerActionProto convertToProtoFormat(LocalizerAction a) {
  return LocalizerActionProto.valueOf(a.name());
}
 

import org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalizerAction; //导入依赖的package包/类
private LocalizerAction convertFromProtoFormat(LocalizerActionProto a) {
  return LocalizerAction.valueOf(a.name());
}
 

import org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalizerAction; //导入依赖的package包/类
MockLocalizerHeartbeatResponse(
    LocalizerAction action, List<ResourceLocalizationSpec> resources) {
  this.action = action;
  this.resourceSpecs = resources;
}
 

import org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalizerAction; //导入依赖的package包/类
public void setLocalizerAction(LocalizerAction action) {
  this.action = action;
}