import org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.NodeHeartbeatResponseProtoOrBuilder; //导入依赖的package包/类
@Override
public MasterKey getContainerTokenMasterKey() {
  NodeHeartbeatResponseProtoOrBuilder p = viaProto ? proto : builder;
  if (this.containerTokenMasterKey != null) {
    return this.containerTokenMasterKey;
  }
  if (!p.hasContainerTokenMasterKey()) {
    return null;
  }
  this.containerTokenMasterKey =
      convertFromProtoFormat(p.getContainerTokenMasterKey());
  return this.containerTokenMasterKey;
}
 

import org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.NodeHeartbeatResponseProtoOrBuilder; //导入依赖的package包/类
@Override
public MasterKey getNMTokenMasterKey() {
  NodeHeartbeatResponseProtoOrBuilder p = viaProto ? proto : builder;
  if (this.nmTokenMasterKey != null) {
    return this.nmTokenMasterKey;
  }
  if (!p.hasNmTokenMasterKey()) {
    return null;
  }
  this.nmTokenMasterKey =
      convertFromProtoFormat(p.getNmTokenMasterKey());
  return this.nmTokenMasterKey;
}
 

import org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.NodeHeartbeatResponseProtoOrBuilder; //导入依赖的package包/类
@Override
public NodeAction getNodeAction() {
  NodeHeartbeatResponseProtoOrBuilder p = viaProto ? proto : builder;
  if (!p.hasNodeAction()) {
    return null;
  }
  return (convertFromProtoFormat(p.getNodeAction()));
}
 

import org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.NodeHeartbeatResponseProtoOrBuilder; //导入依赖的package包/类
@Override
public String getDiagnosticsMessage() {
  NodeHeartbeatResponseProtoOrBuilder p = viaProto ? proto : builder;
  if (!p.hasDiagnosticsMessage()) {
    return null;
  }
  return p.getDiagnosticsMessage();
}
 

import org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.NodeHeartbeatResponseProtoOrBuilder; //导入依赖的package包/类
private void initContainersToCleanup() {
  if (this.containersToCleanup != null) {
    return;
  }
  NodeHeartbeatResponseProtoOrBuilder p = viaProto ? proto : builder;
  List<ContainerIdProto> list = p.getContainersToCleanupList();
  this.containersToCleanup = new ArrayList<ContainerId>();

  for (ContainerIdProto c : list) {
    this.containersToCleanup.add(convertFromProtoFormat(c));
  }
}
 

import org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.NodeHeartbeatResponseProtoOrBuilder; //导入依赖的package包/类
private void initContainersToBeRemovedFromNM() {
  if (this.containersToBeRemovedFromNM != null) {
    return;
  }
  NodeHeartbeatResponseProtoOrBuilder p = viaProto ? proto : builder;
  List<ContainerIdProto> list = p.getContainersToBeRemovedFromNmList();
  this.containersToBeRemovedFromNM = new ArrayList<ContainerId>();

  for (ContainerIdProto c : list) {
    this.containersToBeRemovedFromNM.add(convertFromProtoFormat(c));
  }
}
 

import org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.NodeHeartbeatResponseProtoOrBuilder; //导入依赖的package包/类
private void initApplicationsToCleanup() {
  if (this.applicationsToCleanup != null) {
    return;
  }
  NodeHeartbeatResponseProtoOrBuilder p = viaProto ? proto : builder;
  List<ApplicationIdProto> list = p.getApplicationsToCleanupList();
  this.applicationsToCleanup = new ArrayList<ApplicationId>();

  for (ApplicationIdProto c : list) {
    this.applicationsToCleanup.add(convertFromProtoFormat(c));
  }
}
 

import org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.NodeHeartbeatResponseProtoOrBuilder; //导入依赖的package包/类
private void initSystemCredentials() {
  NodeHeartbeatResponseProtoOrBuilder p = viaProto ? proto : builder;
  List<SystemCredentialsForAppsProto> list = p.getSystemCredentialsForAppsList();
  this.systemCredentials = new HashMap<ApplicationId, ByteBuffer> ();
  for (SystemCredentialsForAppsProto c : list) {
    ApplicationId appId = convertFromProtoFormat(c.getAppId());
    ByteBuffer byteBuffer = ProtoUtils.convertFromProtoFormat(c.getCredentialsForApp());
    this.systemCredentials.put(appId, byteBuffer);
  }
}
 

import org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.NodeHeartbeatResponseProtoOrBuilder; //导入依赖的package包/类
private void initContainersToDecrease() {
  if (this.containersToDecrease != null) {
    return;
  }
  NodeHeartbeatResponseProtoOrBuilder p = viaProto ? proto : builder;
  List<ContainerProto> list = p.getContainersToDecreaseList();
  this.containersToDecrease = new ArrayList<>();

  for (ContainerProto c : list) {
    this.containersToDecrease.add(convertFromProtoFormat(c));
  }
}
 

import org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.NodeHeartbeatResponseProtoOrBuilder; //导入依赖的package包/类
private void initContainersToSignal() {
  if (this.containersToSignal != null) {
    return;
  }
  NodeHeartbeatResponseProtoOrBuilder p = viaProto ? proto : builder;
  List<SignalContainerRequestProto> list = p.getContainersToSignalList();
  this.containersToSignal = new ArrayList<SignalContainerRequest>();

  for (SignalContainerRequestProto c : list) {
    this.containersToSignal.add(convertFromProtoFormat(c));
  }
}
 

import org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.NodeHeartbeatResponseProtoOrBuilder; //导入依赖的package包/类
private void initContainersToUpdate(){
 if(this.containersToUpdate != null) {
  return;
 }
 NodeHeartbeatResponseProtoOrBuilder p = viaProto ? proto : builder;
 List<NodeContainerUpdateProto> list = p.getContainersToUpdateList();
 this.containersToUpdate = new ArrayList<NodeContainerUpdate>();
 
 for(NodeContainerUpdateProto c : list){
  this.containersToUpdate.add(convertFromProtoFormat(c));
 }
}