diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/api/protocolrecords/NodeHeartbeatResponse.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/api/protocolrecords/NodeHeartbeatResponse.java index 09cafaf..7568bbb 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/api/protocolrecords/NodeHeartbeatResponse.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/api/protocolrecords/NodeHeartbeatResponse.java @@ -32,62 +32,85 @@ import org.apache.hadoop.yarn.server.api.records.MasterKey; import org.apache.hadoop.yarn.server.api.records.NodeAction; -public interface NodeHeartbeatResponse { - int getResponseId(); - NodeAction getNodeAction(); +/** + * Node Manager's heartbeat response. + */ +public abstract class NodeHeartbeatResponse { + public abstract int getResponseId(); + + public abstract NodeAction getNodeAction(); - List getContainersToCleanup(); - List getContainersToBeRemovedFromNM(); + public abstract List getContainersToCleanup(); - List getApplicationsToCleanup(); + public abstract List getContainersToBeRemovedFromNM(); + + public abstract List getApplicationsToCleanup(); // This tells NM the collectors' address info of related apps - Map getAppCollectorsMap(); - void setAppCollectorsMap(Map appCollectorsMap); + public abstract Map getAppCollectorsMap(); - void setResponseId(int responseId); - void setNodeAction(NodeAction action); + public abstract void setAppCollectorsMap( + Map appCollectorsMap); - MasterKey getContainerTokenMasterKey(); - void setContainerTokenMasterKey(MasterKey secretKey); - - MasterKey getNMTokenMasterKey(); - void setNMTokenMasterKey(MasterKey secretKey); + public abstract void setResponseId(int responseId); + + public abstract void setNodeAction(NodeAction action); - void addAllContainersToCleanup(List containers); + public abstract MasterKey getContainerTokenMasterKey(); + + public abstract void setContainerTokenMasterKey(MasterKey secretKey); + + public abstract MasterKey getNMTokenMasterKey(); + + public abstract void setNMTokenMasterKey(MasterKey secretKey); + + public abstract void addAllContainersToCleanup(List containers); // This tells NM to remove finished containers from its context. Currently, NM // will remove finished containers from its context only after AM has actually // received the finished containers in a previous allocate response - void addContainersToBeRemovedFromNM(List containers); - - void addAllApplicationsToCleanup(List applications); + public abstract void addContainersToBeRemovedFromNM( + List containers); - List getContainersToSignalList(); - void addAllContainersToSignal(List containers); - long getNextHeartBeatInterval(); - void setNextHeartBeatInterval(long nextHeartBeatInterval); - - String getDiagnosticsMessage(); + public abstract void addAllApplicationsToCleanup( + List applications); + + public abstract List getContainersToSignalList(); + + public abstract void addAllContainersToSignal( + List containers); + + public abstract long getNextHeartBeatInterval(); + + public abstract void setNextHeartBeatInterval(long nextHeartBeatInterval); - void setDiagnosticsMessage(String diagnosticsMessage); + public abstract String getDiagnosticsMessage(); + + public abstract void setDiagnosticsMessage(String diagnosticsMessage); // Credentials (i.e. hdfs tokens) needed by NodeManagers for application // localizations and logAggreations. - Map getSystemCredentialsForApps(); + public abstract Map getSystemCredentialsForApps(); - void setSystemCredentialsForApps( + public abstract void setSystemCredentialsForApps( Map systemCredentials); - boolean getAreNodeLabelsAcceptedByRM(); - void setAreNodeLabelsAcceptedByRM(boolean areNodeLabelsAcceptedByRM); + public abstract boolean getAreNodeLabelsAcceptedByRM(); + + public abstract void setAreNodeLabelsAcceptedByRM( + boolean areNodeLabelsAcceptedByRM); + + public abstract Resource getResource(); + + public abstract void setResource(Resource resource); + + public abstract List getContainersToDecrease(); - Resource getResource(); - void setResource(Resource resource); + public abstract void addAllContainersToDecrease( + Collection containersToDecrease); - List getContainersToDecrease(); - void addAllContainersToDecrease(Collection containersToDecrease); + public abstract ContainerQueuingLimit getContainerQueuingLimit(); - ContainerQueuingLimit getContainerQueuingLimit(); - void setContainerQueuingLimit(ContainerQueuingLimit containerQueuingLimit); + public abstract void setContainerQueuingLimit( + ContainerQueuingLimit containerQueuingLimit); } diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/api/protocolrecords/RegisterNodeManagerResponse.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/api/protocolrecords/RegisterNodeManagerResponse.java index fb1da4c..675b375 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/api/protocolrecords/RegisterNodeManagerResponse.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/api/protocolrecords/RegisterNodeManagerResponse.java @@ -22,34 +22,40 @@ import org.apache.hadoop.yarn.server.api.records.MasterKey; import org.apache.hadoop.yarn.server.api.records.NodeAction; -public interface RegisterNodeManagerResponse { - MasterKey getContainerTokenMasterKey(); +/** + * Node Manager's register response. + */ +public abstract class RegisterNodeManagerResponse { + public abstract MasterKey getContainerTokenMasterKey(); + + public abstract void setContainerTokenMasterKey(MasterKey secretKey); + + public abstract MasterKey getNMTokenMasterKey(); - void setContainerTokenMasterKey(MasterKey secretKey); + public abstract void setNMTokenMasterKey(MasterKey secretKey); - MasterKey getNMTokenMasterKey(); + public abstract NodeAction getNodeAction(); - void setNMTokenMasterKey(MasterKey secretKey); + public abstract void setNodeAction(NodeAction nodeAction); - NodeAction getNodeAction(); + public abstract long getRMIdentifier(); - void setNodeAction(NodeAction nodeAction); + public abstract void setRMIdentifier(long rmIdentifier); - long getRMIdentifier(); + public abstract String getDiagnosticsMessage(); - void setRMIdentifier(long rmIdentifier); + public abstract void setDiagnosticsMessage(String diagnosticsMessage); - String getDiagnosticsMessage(); + public abstract void setRMVersion(String version); - void setDiagnosticsMessage(String diagnosticsMessage); + public abstract String getRMVersion(); - void setRMVersion(String version); + public abstract Resource getResource(); - String getRMVersion(); + public abstract void setResource(Resource resource); - Resource getResource(); - void setResource(Resource resource); + public abstract boolean getAreNodeLabelsAcceptedByRM(); - boolean getAreNodeLabelsAcceptedByRM(); - void setAreNodeLabelsAcceptedByRM(boolean areNodeLabelsAcceptedByRM); + public abstract void setAreNodeLabelsAcceptedByRM( + boolean areNodeLabelsAcceptedByRM); } diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/api/protocolrecords/impl/pb/NodeHeartbeatResponsePBImpl.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/api/protocolrecords/impl/pb/NodeHeartbeatResponsePBImpl.java index cd85241..37bf570 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/api/protocolrecords/impl/pb/NodeHeartbeatResponsePBImpl.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/api/protocolrecords/impl/pb/NodeHeartbeatResponsePBImpl.java @@ -35,7 +35,6 @@ import org.apache.hadoop.yarn.api.records.impl.pb.ApplicationIdPBImpl; import org.apache.hadoop.yarn.api.records.impl.pb.ContainerIdPBImpl; import org.apache.hadoop.yarn.api.records.impl.pb.ContainerPBImpl; -import org.apache.hadoop.yarn.api.records.impl.pb.ProtoBase; import org.apache.hadoop.yarn.api.records.impl.pb.ProtoUtils; import org.apache.hadoop.yarn.api.records.impl.pb.ResourcePBImpl; import org.apache.hadoop.yarn.proto.YarnProtos.ApplicationIdProto; @@ -57,12 +56,14 @@ import org.apache.hadoop.yarn.server.api.records.impl.pb.ContainerQueuingLimitPBImpl; import org.apache.hadoop.yarn.server.api.records.impl.pb.MasterKeyPBImpl; - -public class NodeHeartbeatResponsePBImpl extends - ProtoBase implements NodeHeartbeatResponse { - NodeHeartbeatResponseProto proto = NodeHeartbeatResponseProto.getDefaultInstance(); - NodeHeartbeatResponseProto.Builder builder = null; - boolean viaProto = false; +/** + * PBImpl class for NodeHeartbeatResponse. + */ +public class NodeHeartbeatResponsePBImpl extends NodeHeartbeatResponse { + private NodeHeartbeatResponseProto proto = NodeHeartbeatResponseProto + .getDefaultInstance(); + private NodeHeartbeatResponseProto.Builder builder = null; + private boolean viaProto = false; private List containersToCleanup = null; private List containersToBeRemovedFromNM = null; diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/api/protocolrecords/impl/pb/RegisterNodeManagerResponsePBImpl.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/api/protocolrecords/impl/pb/RegisterNodeManagerResponsePBImpl.java index 56b675b..2121fd1 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/api/protocolrecords/impl/pb/RegisterNodeManagerResponsePBImpl.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server/api/protocolrecords/impl/pb/RegisterNodeManagerResponsePBImpl.java @@ -20,7 +20,6 @@ import org.apache.hadoop.yarn.api.records.Resource; -import org.apache.hadoop.yarn.api.records.impl.pb.ProtoBase; import org.apache.hadoop.yarn.api.records.impl.pb.ResourcePBImpl; import org.apache.hadoop.yarn.proto.YarnProtos.ResourceProto; import org.apache.hadoop.yarn.proto.YarnServerCommonProtos.MasterKeyProto; @@ -32,11 +31,15 @@ import org.apache.hadoop.yarn.server.api.records.NodeAction; import org.apache.hadoop.yarn.server.api.records.impl.pb.MasterKeyPBImpl; - -public class RegisterNodeManagerResponsePBImpl extends ProtoBase implements RegisterNodeManagerResponse { - RegisterNodeManagerResponseProto proto = RegisterNodeManagerResponseProto.getDefaultInstance(); - RegisterNodeManagerResponseProto.Builder builder = null; - boolean viaProto = false; +/** + * PBImpl class for RegisterNodeManagerResponse. + */ +public class RegisterNodeManagerResponsePBImpl + extends RegisterNodeManagerResponse { + private RegisterNodeManagerResponseProto proto = + RegisterNodeManagerResponseProto.getDefaultInstance(); + private RegisterNodeManagerResponseProto.Builder builder = null; + private boolean viaProto = false; private Resource resource = null; private MasterKey containerTokenMasterKey = null;