Package org.apache.hadoop.yarn.server.resourcemanager.scheduler.activities

Class AppAllocation

java.lang.Object
org.apache.hadoop.yarn.server.resourcemanager.scheduler.activities.AppAllocation
public class AppAllocation extends Object
It contains allocation information for one application within a period of time. Each application allocation may have several allocation attempts.

  • Constructor Details

    • AppAllocation

      public AppAllocation(org.apache.hadoop.yarn.api.records.Priority priority, org.apache.hadoop.yarn.api.records.NodeId nodeId, String queueName)

  • Method Details

    • updateAppContainerStateAndTime

      public void updateAppContainerStateAndTime(org.apache.hadoop.yarn.api.records.ContainerId cId, ActivityState appState, long ts, String diagnostic)

    • addAppAllocationActivity

      public void addAppAllocationActivity(String cId, Integer reqPriority, ActivityState state, String diagnose, ActivityLevel level, org.apache.hadoop.yarn.api.records.NodeId nId, Long allocationRequestId)

    • getNodeId

      public String getNodeId()

    • getQueueName

      public String getQueueName()

    • getActivityState

      public ActivityState getActivityState()

    • getPriority

      public org.apache.hadoop.yarn.api.records.Priority getPriority()

    • getContainerId

      public String getContainerId()

    • getDiagnostic

      public String getDiagnostic()

    • getTime

      public long getTime()

    • getAllocationAttempts

      public List<ActivityNode> getAllocationAttempts()

    • filterAllocationAttempts

      public AppAllocation filterAllocationAttempts(Set<Integer> requestPriorities, Set<Long> allocationRequestIds)

    • setAllocationAttempts

      public void setAllocationAttempts(List<ActivityNode> allocationAttempts)