org.apache.giraph.counters

Class GiraphTimers

java.lang.Object

org.apache.giraph.counters.HadoopCountersBase

org.apache.giraph.counters.GiraphTimers

All Implemented Interfaces:

Iterable<GiraphHadoopCounter>

public class GiraphTimers
extends HadoopCountersBase

Hadoop Counters in group "Giraph Timers" for timing things.

Field Summary

Fields

Modifier and Type	Field and Description
static String	GROUP_NAME Counter group name for the giraph timers
static String	INITIALIZE_MS_NAME Counter name for initialize msec
static String	SETUP_MS_NAME Counter name for setup msec
static String	SHUTDOWN_MS_NAME Counter name for shutdown msec
static String	TOTAL_MS_NAME Counter name for total msec

Method Summary

Modifier and Type	Method and Description
List<CustomCounter>	getCounterList(long superstep) Get a map of counter names and values for the given superstep Counters include Setup, Initialise, Shutdown, Total, and time for the given superstep
GiraphHadoopCounter	getInitializeMs() Get counter for initializing the process, having to wait for a minimum number of processes to be available before setup step
static GiraphTimers	getInstance() Get singleton instance.
GiraphHadoopCounter	getSetupMs() Get counter for setup time in milliseconds
GiraphHadoopCounter	getShutdownMs() Get counter for shutdown time in milliseconds.
GiraphHadoopCounter	getSuperstepMs(long superstep, String computationName) Get counter for superstep time in milliseconds
GiraphHadoopCounter	getTotalMs() Get counter for total time in milliseconds (doesn't include initialize time).
static void	init(org.apache.hadoop.mapreduce.Mapper.Context context) Instantiate with Hadoop Context.
Iterator<GiraphHadoopCounter>	iterator()
Iterable<GiraphHadoopCounter>	jobCounters() Get Iterable through job counters.
Map<Long,GiraphHadoopCounter>	superstepCounters() Get map of superstep to msec counter.

Methods inherited from class org.apache.giraph.counters.HadoopCountersBase

getContext, getCounter

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Detail

GROUP_NAME

public static final String GROUP_NAME

Counter group name for the giraph timers

See Also:

Constant Field Values

SETUP_MS_NAME

public static final String SETUP_MS_NAME

Counter name for setup msec

See Also:

Constant Field Values

TOTAL_MS_NAME

public static final String TOTAL_MS_NAME

Counter name for total msec

See Also:

Constant Field Values

SHUTDOWN_MS_NAME

public static final String SHUTDOWN_MS_NAME

Counter name for shutdown msec

See Also:

Constant Field Values

INITIALIZE_MS_NAME

public static final String INITIALIZE_MS_NAME

Counter name for initialize msec

See Also:

Constant Field Values

Method Detail

init

public static void init(org.apache.hadoop.mapreduce.Mapper.Context context)

Instantiate with Hadoop Context.

Parameters:

context - Hadoop Context to use.

getInstance

public static GiraphTimers getInstance()

Get singleton instance.

Returns:

singleton GiraphTimers instance.

getSetupMs

public GiraphHadoopCounter getSetupMs()

Get counter for setup time in milliseconds

Returns:

Counter for setup time in milliseconds

getSuperstepMs

public GiraphHadoopCounter getSuperstepMs(long superstep,
                                          String computationName)

Get counter for superstep time in milliseconds

Parameters:

superstep - Integer superstep number.

computationName - Name of the computation for display (may be null)

Returns:

Counter for setup time in milliseconds

getTotalMs

public GiraphHadoopCounter getTotalMs()

Get counter for total time in milliseconds (doesn't include initialize time).

Returns:

Counter for total time in milliseconds.

getShutdownMs

public GiraphHadoopCounter getShutdownMs()

Get counter for shutdown time in milliseconds.

Returns:

Counter for shutdown time in milliseconds.

getInitializeMs

public GiraphHadoopCounter getInitializeMs()

Get counter for initializing the process, having to wait for a minimum number of processes to be available before setup step

Returns:

Counter for initializing in milliseconds

superstepCounters

public Map<Long,GiraphHadoopCounter> superstepCounters()

Get map of superstep to msec counter.

Returns:

mapping of superstep to msec counter.

jobCounters

public Iterable<GiraphHadoopCounter> jobCounters()

Get Iterable through job counters.

Returns:

Iterable of job counters.

iterator

public Iterator<GiraphHadoopCounter> iterator()

getCounterList

public List<CustomCounter> getCounterList(long superstep)

Get a map of counter names and values for the given superstep Counters include Setup, Initialise, Shutdown, Total, and time for the given superstep

Parameters:

superstep - superstep for which to fetch the GiraphTimer

Returns:

Map of counter names and values