@Metrics(about="Metrics for node manager", context="yarn") public class NodeManagerMetrics extends Object
Constructor and Description |
---|
NodeManagerMetrics(org.apache.hadoop.metrics2.source.JvmMetrics jvmMetrics) |
Modifier and Type | Method and Description |
---|---|
void |
addContainerLaunchDuration(long value) |
void |
addResource(org.apache.hadoop.yarn.api.records.Resource res) |
void |
allocateContainer(org.apache.hadoop.yarn.api.records.Resource res) |
void |
changeContainer(org.apache.hadoop.yarn.api.records.Resource before,
org.apache.hadoop.yarn.api.records.Resource now) |
void |
completedContainer() |
void |
completeOpportunisticContainer(org.apache.hadoop.yarn.api.records.Resource res) |
static NodeManagerMetrics |
create() |
void |
endInitingContainer() |
void |
endReInitingContainer() |
void |
endRunningContainer() |
void |
failedContainer() |
long |
getAllocatedOpportunisticGB() |
int |
getAllocatedOpportunisticVCores() |
int |
getBadLocalDirs() |
int |
getBadLogDirs() |
long |
getCacheSizeBeforeClean() |
int |
getCompletedContainers() |
int |
getContainersRolledbackOnFailure() |
int |
getFailedContainers() |
int |
getGoodLocalDirsDiskUtilizationPerc() |
int |
getGoodLogDirsDiskUtilizationPerc() |
org.apache.hadoop.metrics2.source.JvmMetrics |
getJvmMetrics() |
int |
getKilledContainers() |
long |
getPrivateBytesDeleted() |
long |
getPublicBytesDeleted() |
int |
getReInitializingContainer() |
int |
getRunningContainers() |
int |
getRunningOpportunisticContainers() |
long |
getTotalBytesDeleted() |
void |
initingContainer() |
void |
killedContainer() |
void |
launchedContainer() |
void |
reInitingContainer() |
void |
releaseContainer(org.apache.hadoop.yarn.api.records.Resource res) |
void |
rollbackContainerOnFailure() |
void |
runningContainer() |
void |
setBadLocalDirs(int badLocalDirs) |
void |
setBadLogDirs(int badLogDirs) |
void |
setCacheSizeBeforeClean(long cacheSizeBeforeClean) |
void |
setGoodLocalDirsDiskUtilizationPerc(int goodLocalDirsDiskUtilizationPerc) |
void |
setGoodLogDirsDiskUtilizationPerc(int goodLogDirsDiskUtilizationPerc) |
void |
setPrivateBytesDeleted(long privateBytesDeleted) |
void |
setPublicBytesDeleted(long publicBytesDeleted) |
void |
setTotalBytesDeleted(long totalBytesDeleted) |
void |
startOpportunisticContainer(org.apache.hadoop.yarn.api.records.Resource res) |
public NodeManagerMetrics(org.apache.hadoop.metrics2.source.JvmMetrics jvmMetrics)
public static NodeManagerMetrics create()
public org.apache.hadoop.metrics2.source.JvmMetrics getJvmMetrics()
public void launchedContainer()
public void completedContainer()
public void rollbackContainerOnFailure()
public void failedContainer()
public void killedContainer()
public void initingContainer()
public void endInitingContainer()
public void runningContainer()
public void endRunningContainer()
public void reInitingContainer()
public void endReInitingContainer()
public void allocateContainer(org.apache.hadoop.yarn.api.records.Resource res)
public void releaseContainer(org.apache.hadoop.yarn.api.records.Resource res)
public void changeContainer(org.apache.hadoop.yarn.api.records.Resource before, org.apache.hadoop.yarn.api.records.Resource now)
public void startOpportunisticContainer(org.apache.hadoop.yarn.api.records.Resource res)
public void completeOpportunisticContainer(org.apache.hadoop.yarn.api.records.Resource res)
public void addResource(org.apache.hadoop.yarn.api.records.Resource res)
public void addContainerLaunchDuration(long value)
public void setBadLocalDirs(int badLocalDirs)
public void setBadLogDirs(int badLogDirs)
public void setGoodLocalDirsDiskUtilizationPerc(int goodLocalDirsDiskUtilizationPerc)
public void setGoodLogDirsDiskUtilizationPerc(int goodLogDirsDiskUtilizationPerc)
public void setCacheSizeBeforeClean(long cacheSizeBeforeClean)
public void setTotalBytesDeleted(long totalBytesDeleted)
public void setPublicBytesDeleted(long publicBytesDeleted)
public void setPrivateBytesDeleted(long privateBytesDeleted)
public int getRunningContainers()
public int getKilledContainers()
public int getFailedContainers()
public int getCompletedContainers()
public int getBadLogDirs()
public int getBadLocalDirs()
public int getGoodLogDirsDiskUtilizationPerc()
public int getGoodLocalDirsDiskUtilizationPerc()
public int getReInitializingContainer()
public int getContainersRolledbackOnFailure()
public long getAllocatedOpportunisticGB()
public int getAllocatedOpportunisticVCores()
public int getRunningOpportunisticContainers()
public long getCacheSizeBeforeClean()
public long getTotalBytesDeleted()
public long getPublicBytesDeleted()
public long getPrivateBytesDeleted()
Copyright © 2018 Apache Software Foundation. All Rights Reserved.