Package org.apache.hadoop.yarn.server.api.protocolrecords

Class NodeHeartbeatResponse

java.lang.Object
org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse
Direct Known Subclasses:
NodeHeartbeatResponsePBImpl
public abstract class NodeHeartbeatResponse extends Object
Node Manager's heartbeat response.

  • Constructor Details

    • NodeHeartbeatResponse

      public NodeHeartbeatResponse()

  • Method Details

    • getResponseId

      public abstract int getResponseId()

    • getNodeAction

      public abstract NodeAction getNodeAction()

    • getContainersToCleanup

      public abstract List<org.apache.hadoop.yarn.api.records.ContainerId> getContainersToCleanup()

    • getContainersToBeRemovedFromNM

      public abstract List<org.apache.hadoop.yarn.api.records.ContainerId> getContainersToBeRemovedFromNM()

    • getApplicationsToCleanup

      public abstract List<org.apache.hadoop.yarn.api.records.ApplicationId> getApplicationsToCleanup()

    • getAppCollectors

      public abstract Map<org.apache.hadoop.yarn.api.records.ApplicationId,AppCollectorData> getAppCollectors()

    • setAppCollectors

      public abstract void setAppCollectors(Map<org.apache.hadoop.yarn.api.records.ApplicationId,AppCollectorData> appCollectorsMap)

    • setResponseId

      public abstract void setResponseId(int responseId)

    • setNodeAction

      public abstract void setNodeAction(NodeAction action)

    • getContainerTokenMasterKey

      public abstract MasterKey getContainerTokenMasterKey()

    • setContainerTokenMasterKey

      public abstract void setContainerTokenMasterKey(MasterKey secretKey)

    • getNMTokenMasterKey

      public abstract MasterKey getNMTokenMasterKey()

    • setNMTokenMasterKey

      public abstract void setNMTokenMasterKey(MasterKey secretKey)

    • addAllContainersToCleanup

      public abstract void addAllContainersToCleanup(List<org.apache.hadoop.yarn.api.records.ContainerId> containers)

    • addContainersToBeRemovedFromNM

      public abstract void addContainersToBeRemovedFromNM(List<org.apache.hadoop.yarn.api.records.ContainerId> containers)

    • addAllApplicationsToCleanup

      public abstract void addAllApplicationsToCleanup(List<org.apache.hadoop.yarn.api.records.ApplicationId> applications)

    • getContainersToSignalList

      public abstract List<org.apache.hadoop.yarn.api.protocolrecords.SignalContainerRequest> getContainersToSignalList()

    • addAllContainersToSignal

      public abstract void addAllContainersToSignal(List<org.apache.hadoop.yarn.api.protocolrecords.SignalContainerRequest> containers)

    • getNextHeartBeatInterval

      public abstract long getNextHeartBeatInterval()

    • setNextHeartBeatInterval

      public abstract void setNextHeartBeatInterval(long nextHeartBeatInterval)

    • getDiagnosticsMessage

      public abstract String getDiagnosticsMessage()

    • setDiagnosticsMessage

      public abstract void setDiagnosticsMessage(String diagnosticsMessage)

    • getAreNodeLabelsAcceptedByRM

      public abstract boolean getAreNodeLabelsAcceptedByRM()

    • setAreNodeLabelsAcceptedByRM

      public abstract void setAreNodeLabelsAcceptedByRM(boolean areNodeLabelsAcceptedByRM)

    • getResource

      public abstract org.apache.hadoop.yarn.api.records.Resource getResource()

    • setResource

      public abstract void setResource(org.apache.hadoop.yarn.api.records.Resource resource)

    • getContainersToUpdate

      public abstract List<org.apache.hadoop.yarn.api.records.Container> getContainersToUpdate()

    • addAllContainersToUpdate

      public abstract void addAllContainersToUpdate(Collection<org.apache.hadoop.yarn.api.records.Container> containersToUpdate)

    • getContainerQueuingLimit

      public abstract ContainerQueuingLimit getContainerQueuingLimit()

    • setContainerQueuingLimit

      public abstract void setContainerQueuingLimit(ContainerQueuingLimit containerQueuingLimit)

    • getContainersToDecrease

      public abstract List<org.apache.hadoop.yarn.api.records.Container> getContainersToDecrease()

    • addAllContainersToDecrease

      public abstract void addAllContainersToDecrease(Collection<org.apache.hadoop.yarn.api.records.Container> containersToDecrease)

    • getAreNodeAttributesAcceptedByRM

      public abstract boolean getAreNodeAttributesAcceptedByRM()

    • setAreNodeAttributesAcceptedByRM

      public abstract void setAreNodeAttributesAcceptedByRM(boolean areNodeAttributesAcceptedByRM)

    • setTokenSequenceNo

      public abstract void setTokenSequenceNo(long tokenSequenceNo)

    • getTokenSequenceNo

      public abstract long getTokenSequenceNo()

    • setSystemCredentialsForApps

      public abstract void setSystemCredentialsForApps(Collection<org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.SystemCredentialsForAppsProto> systemCredentials)

    • getSystemCredentialsForApps

      public abstract Collection<org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.SystemCredentialsForAppsProto> getSystemCredentialsForApps()