org.apache.storm.metric.cgroup

Class CGroupMetricsBase<T>

java.lang.Object

org.apache.storm.metric.cgroup.CGroupMetricsBase<T>

All Implemented Interfaces:

IMetric

Direct Known Subclasses:

CGroupCpu, CGroupCpuGuarantee, CGroupMemoryLimit, CGroupMemoryUsage

public abstract class CGroupMetricsBase<T>
extends Object
implements IMetric

Base class for checking if CGroups are enabled, etc.

Constructor Summary

Constructors

Constructor and Description
CGroupMetricsBase(Map<String,Object> conf, SubSystemType type)

Method Summary

Modifier and Type	Method and Description
abstract T	getDataFrom(CgroupCore core)
Object	getValueAndReset()

Methods inherited from class java.lang.Object

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

Constructor Detail

CGroupMetricsBase

public CGroupMetricsBase(Map<String,Object> conf,
                         SubSystemType type)

Method Detail

getValueAndReset

public Object getValueAndReset()

Specified by:

getValueAndReset in interface IMetric

Returns:

an object that will be sent sent to IMetricsConsumer#handleDataPoints(org.apache.storm.metric.api.IMetricsConsumer .TaskInfo, java.util.Collection). If null is returned nothing will be sent. If this value can be reset, like with a counter, a side effect of calling this should be that the value is reset.

getDataFrom

public abstract T getDataFrom(CgroupCore core)
                       throws Exception

Throws:

Exception