Package org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.resources

Class AbstractCGroupsResourceCalculator

java.lang.Object

org.apache.hadoop.conf.Configured

org.apache.hadoop.yarn.util.ResourceCalculatorProcessTree

org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.resources.AbstractCGroupsResourceCalculator

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable

Direct Known Subclasses:

CGroupsResourceCalculator, CGroupsV2ResourceCalculator

public abstract class AbstractCGroupsResourceCalculator
extends org.apache.hadoop.yarn.util.ResourceCalculatorProcessTree

Common code base for the CGroupsResourceCalculator implementations.

Field Summary

Fields inherited from class org.apache.hadoop.yarn.util.ResourceCalculatorProcessTree

UNAVAILABLE

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractCGroupsResourceCalculator(String pid, List<String> totalJiffiesKeys, String rssMemoryKey, String virtualMemoryKey)

Method Summary

Modifier and Type	Method	Description
boolean	checkPidPgrpidForMatch()
protected List<String>	fileToLines(Path path)
protected String	fileToString(Path path)
protected abstract List<Path>	getCGroupFilesToLoadInStats()
CGroupsHandler	getcGroupsHandler()
float	getCpuUsagePercent()
long	getCumulativeCpuTime()
String	getPid()
String	getProcessTreeDump()
long	getRssMemorySize(int olderThanAge)
long	getVirtualMemorySize(int olderThanAge)
void	initialize()
protected List<String>	readLinesFromCGroupFileFromProcDir()
void	updateProcessTree()

Methods inherited from class org.apache.hadoop.yarn.util.ResourceCalculatorProcessTree

getResourceCalculatorProcessTree, getRssMemorySize, getVirtualMemorySize

Methods inherited from class org.apache.hadoop.conf.Configured

getConf, setConf

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AbstractCGroupsResourceCalculator

protected AbstractCGroupsResourceCalculator(String pid,
 List<String> totalJiffiesKeys,
 String rssMemoryKey,
 String virtualMemoryKey)

Method Details

initialize

public void initialize()
                throws org.apache.hadoop.yarn.exceptions.YarnException

Overrides:

initialize in class org.apache.hadoop.yarn.util.ResourceCalculatorProcessTree

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

getCumulativeCpuTime

public long getCumulativeCpuTime()

Overrides:

getCumulativeCpuTime in class org.apache.hadoop.yarn.util.ResourceCalculatorProcessTree

getRssMemorySize

public long getRssMemorySize(int olderThanAge)

Overrides:

getRssMemorySize in class org.apache.hadoop.yarn.util.ResourceCalculatorProcessTree

getVirtualMemorySize

public long getVirtualMemorySize(int olderThanAge)

Overrides:

getVirtualMemorySize in class org.apache.hadoop.yarn.util.ResourceCalculatorProcessTree

getProcessTreeDump

public String getProcessTreeDump()

Specified by:

getProcessTreeDump in class org.apache.hadoop.yarn.util.ResourceCalculatorProcessTree

checkPidPgrpidForMatch

public boolean checkPidPgrpidForMatch()

Specified by:

checkPidPgrpidForMatch in class org.apache.hadoop.yarn.util.ResourceCalculatorProcessTree

getCpuUsagePercent

public float getCpuUsagePercent()

Overrides:

getCpuUsagePercent in class org.apache.hadoop.yarn.util.ResourceCalculatorProcessTree

updateProcessTree

public void updateProcessTree()

Specified by:

updateProcessTree in class org.apache.hadoop.yarn.util.ResourceCalculatorProcessTree

getCGroupFilesToLoadInStats

protected abstract List<Path> getCGroupFilesToLoadInStats()

readLinesFromCGroupFileFromProcDir

protected List<String> readLinesFromCGroupFileFromProcDir()
                                                   throws IOException

Throws:

IOException

fileToString

protected String fileToString(Path path)
                       throws IOException

Throws:

IOException

fileToLines

protected List<String> fileToLines(Path path)
                            throws IOException

Throws:

IOException

getcGroupsHandler

public CGroupsHandler getcGroupsHandler()

getPid

public String getPid()