com.bigdata.counters

Class AbstractProcessCollector

java.lang.Object

com.bigdata.counters.AbstractProcessCollector

All Implemented Interfaces:

ICounterSetAccess, IStatisticsCollector

Direct Known Subclasses:

IOStatCollector, PIDStatCollector, SarCpuUtilizationCollector, TypeperfCollector, VMStatCollector, VMStatCollector

public abstract class AbstractProcessCollector
extends Object
implements IStatisticsCollector

Base class for collection of performance counters as reported by a native process.

Version:

$Id$

Author:

Bryan Thompson

Field Summary

Fields

Modifier and Type	Field and Description
protected ActiveProcess	activeProcess
protected static org.apache.log4j.Logger	log

Constructor Summary

Constructors

Constructor and Description
AbstractProcessCollector(int interval)

Method Summary

Methods

Modifier and Type	Method and Description
abstract List<String>	getCommand()
int	getInterval() The interval in seconds at which the counter values are sampled.
abstract AbstractProcessReader	getProcessReader()
protected void	setEnvironment(Map<String,String> env) Override if you want to impose settings on environment variables.
void	start() Start collecting performance data.
void	stop() Stop collecting performance data.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.bigdata.counters.ICounterSetAccess

getCounters

Field Detail

log

protected static final org.apache.log4j.Logger log

activeProcess

protected ActiveProcess activeProcess

Constructor Detail

AbstractProcessCollector

public AbstractProcessCollector(int interval)

Parameters:

interval - The interval at which the performance counters will be read in milliseconds.

Method Detail

getInterval

public int getInterval()

Description copied from interface: IStatisticsCollector

The interval in seconds at which the counter values are sampled.

Specified by:

getInterval in interface IStatisticsCollector

setEnvironment

protected void setEnvironment(Map<String,String> env)

Override if you want to impose settings on environment variables.

start

public void start()

Start collecting performance data.

Creates the ActiveProcess and the ActiveProcess.start(AbstractProcessReader)s it passing in the value returned by the getProcessReader()

Specified by:

start in interface IStatisticsCollector

stop

public void stop()

Description copied from interface: IStatisticsCollector

Stop collecting performance data.

Specified by:

stop in interface IStatisticsCollector

getCommand

public abstract List<String> getCommand()

getProcessReader

public abstract AbstractProcessReader getProcessReader()