Package org.apache.hadoop.yarn.server.nodemanager.metrics

Class NodeManagerMetrics

java.lang.Object
org.apache.hadoop.yarn.server.nodemanager.metrics.NodeManagerMetrics
@Metrics(about="Metrics for node manager", context="yarn") public class NodeManagerMetrics extends Object

  • Method Details

    • create

      public static NodeManagerMetrics create()

    • getJvmMetrics

      public org.apache.hadoop.metrics2.source.JvmMetrics getJvmMetrics()

    • launchedContainer

      public void launchedContainer()

    • completedContainer

      public void completedContainer()

    • rollbackContainerOnFailure

      public void rollbackContainerOnFailure()

    • failedContainer

      public void failedContainer()

    • killedContainer

      public void killedContainer()

    • initingContainer

      public void initingContainer()

    • endInitingContainer

      public void endInitingContainer()

    • runningContainer

      public void runningContainer()

    • endRunningContainer

      public void endRunningContainer()

    • reInitingContainer

      public void reInitingContainer()

    • endReInitingContainer

      public void endReInitingContainer()

    • runningApplication

      public void runningApplication()

    • endRunningApplication

      public void endRunningApplication()

    • pausedContainer

      public void pausedContainer()

    • endPausedContainer

      public void endPausedContainer()

    • allocateContainer

      public void allocateContainer(org.apache.hadoop.yarn.api.records.Resource res)

    • releaseContainer

      public void releaseContainer(org.apache.hadoop.yarn.api.records.Resource res)

    • changeContainer

      public void changeContainer(org.apache.hadoop.yarn.api.records.Resource before, org.apache.hadoop.yarn.api.records.Resource now)

    • startOpportunisticContainer

      public void startOpportunisticContainer(org.apache.hadoop.yarn.api.records.Resource res)

    • completeOpportunisticContainer

      public void completeOpportunisticContainer(org.apache.hadoop.yarn.api.records.Resource res)

    • setQueuedContainers

      public void setQueuedContainers(int opportunisticCount, int guaranteedCount)

    • addResource

      public void addResource(org.apache.hadoop.yarn.api.records.Resource res)

    • addContainerLaunchDuration

      public void addContainerLaunchDuration(long value)

    • setBadLocalDirs

      public void setBadLocalDirs(int badLocalDirs)

    • setBadLogDirs

      public void setBadLogDirs(int badLogDirs)

    • setGoodLocalDirsDiskUtilizationPerc

      public void setGoodLocalDirsDiskUtilizationPerc(int goodLocalDirsDiskUtilizationPerc)

    • setGoodLogDirsDiskUtilizationPerc

      public void setGoodLogDirsDiskUtilizationPerc(int goodLogDirsDiskUtilizationPerc)

    • setCacheSizeBeforeClean

      public void setCacheSizeBeforeClean(long cacheSizeBeforeClean)

    • setTotalBytesDeleted

      public void setTotalBytesDeleted(long totalBytesDeleted)

    • setPublicBytesDeleted

      public void setPublicBytesDeleted(long publicBytesDeleted)

    • setPrivateBytesDeleted

      public void setPrivateBytesDeleted(long privateBytesDeleted)

    • getRunningContainers

      public int getRunningContainers()

    • getPausedContainers

      public int getPausedContainers()

    • getKilledContainers

      @VisibleForTesting public int getKilledContainers()

    • getFailedContainers

      @VisibleForTesting public int getFailedContainers()

    • getCompletedContainers

      @VisibleForTesting public int getCompletedContainers()

    • getBadLogDirs

      @VisibleForTesting public int getBadLogDirs()

    • getBadLocalDirs

      @VisibleForTesting public int getBadLocalDirs()

    • getGoodLogDirsDiskUtilizationPerc

      @VisibleForTesting public int getGoodLogDirsDiskUtilizationPerc()

    • getGoodLocalDirsDiskUtilizationPerc

      @VisibleForTesting public int getGoodLocalDirsDiskUtilizationPerc()

    • getReInitializingContainer

      @VisibleForTesting public int getReInitializingContainer()

    • getContainersRolledbackOnFailure

      @VisibleForTesting public int getContainersRolledbackOnFailure()

    • getAllocatedOpportunisticGB

      public long getAllocatedOpportunisticGB()

    • getAllocatedOpportunisticVCores

      public int getAllocatedOpportunisticVCores()

    • getRunningOpportunisticContainers

      public int getRunningOpportunisticContainers()

    • getQueuedOpportunisticContainers

      @VisibleForTesting public int getQueuedOpportunisticContainers()

    • getQueuedGuaranteedContainers

      @VisibleForTesting public int getQueuedGuaranteedContainers()

    • getCacheSizeBeforeClean

      public long getCacheSizeBeforeClean()

    • getTotalBytesDeleted

      public long getTotalBytesDeleted()

    • getPublicBytesDeleted

      public long getPublicBytesDeleted()

    • getPrivateBytesDeleted

      public long getPrivateBytesDeleted()

    • setContainerUsedMemGB

      public void setContainerUsedMemGB(long usedMem)

    • getContainerUsedMemGB

      public int getContainerUsedMemGB()

    • setContainerUsedVMemGB

      public void setContainerUsedVMemGB(long usedVMem)

    • getContainerUsedVMemGB

      public int getContainerUsedVMemGB()

    • setContainerCpuUtilization

      public void setContainerCpuUtilization(float cpuUtilization)

    • getContainerCpuUtilization

      public float getContainerCpuUtilization()

    • setNodeUsedMemGB

      public void setNodeUsedMemGB(long totalUsedMemGB)

    • getNodeUsedMemGB

      public int getNodeUsedMemGB()

    • setNodeUsedVMemGB

      public void setNodeUsedVMemGB(long totalUsedVMemGB)

    • getNodeUsedVMemGB

      public int getNodeUsedVMemGB()

    • getNodeCpuUtilization

      public float getNodeCpuUtilization()

    • setNodeCpuUtilization

      public void setNodeCpuUtilization(float cpuUtilization)

    • setNodeGpuUtilization

      public void setNodeGpuUtilization(float nodeGpuUtilization)

    • getNodeGpuUtilization

      public float getNodeGpuUtilization()

    • localizationCacheHitMiss

      public void localizationCacheHitMiss(long size)

    • localizationComplete

      public void localizationComplete(long downloadMillis)

    • addContainerMonitorCostTime

      public void addContainerMonitorCostTime(long duration)