Package org.apache.hadoop.yarn.server.resourcemanager.rmapp.attempt

Class RMAppAttemptMetrics

java.lang.Object
org.apache.hadoop.yarn.server.resourcemanager.rmapp.attempt.RMAppAttemptMetrics
public class RMAppAttemptMetrics extends Object

  • Constructor Details

    • RMAppAttemptMetrics

      public RMAppAttemptMetrics(org.apache.hadoop.yarn.api.records.ApplicationAttemptId attemptId, RMContext rmContext)

  • Method Details

    • updatePreemptionInfo

      public void updatePreemptionInfo(org.apache.hadoop.yarn.api.records.Resource resource, RMContainer container)

    • getResourcePreempted

      public org.apache.hadoop.yarn.api.records.Resource getResourcePreempted()

    • getPreemptedMemory

      public long getPreemptedMemory()

    • getPreemptedVcore

      public long getPreemptedVcore()

    • getPreemptedResourceSecondsMap

      public Map<String,Long> getPreemptedResourceSecondsMap()

    • getNumNonAMContainersPreempted

      public int getNumNonAMContainersPreempted()

    • setIsPreempted

      public void setIsPreempted()

    • getIsPreempted

      public boolean getIsPreempted()

    • getAggregateAppResourceUsage

      public AggregateAppResourceUsage getAggregateAppResourceUsage()

    • updateAggregateAppResourceUsage

      public void updateAggregateAppResourceUsage(org.apache.hadoop.yarn.api.records.Resource allocated, long deltaUsedMillis)

    • updateAggregatePreemptedAppResourceUsage

      public void updateAggregatePreemptedAppResourceUsage(org.apache.hadoop.yarn.api.records.Resource allocated, long deltaUsedMillis)

    • updateAggregateAppResourceUsage

      public void updateAggregateAppResourceUsage(Map<String,Long> resourceSecondsMap)

    • updateAggregatePreemptedAppResourceUsage

      public void updateAggregatePreemptedAppResourceUsage(Map<String,Long> preemptedResourceSecondsMap)

    • incNumAllocatedContainers

      public void incNumAllocatedContainers(NodeType containerType, NodeType requestType)

    • getLocalityStatistics

      public int[][] getLocalityStatistics()

    • getTotalAllocatedContainers

      public int getTotalAllocatedContainers()

    • setTotalAllocatedContainers

      public void setTotalAllocatedContainers(int totalAllocatedContainers)

    • getApplicationAttemptHeadroom

      public org.apache.hadoop.yarn.api.records.Resource getApplicationAttemptHeadroom()

    • setApplicationAttemptHeadRoom

      public void setApplicationAttemptHeadRoom(org.apache.hadoop.yarn.api.records.Resource headRoom)