org.apache.giraph.metrics

Class WorkerSuperstepMetrics

java.lang.Object

org.apache.giraph.metrics.WorkerSuperstepMetrics

All Implemented Interfaces:

org.apache.hadoop.io.Writable

public class WorkerSuperstepMetrics
extends Object
implements org.apache.hadoop.io.Writable

Per-superstep metrics for a Worker.

Constructor Summary

Constructors

Constructor and Description
WorkerSuperstepMetrics() Constructor

Method Summary

Modifier and Type	Method and Description
long	getBytesLoadedFromDisk()
long	getBytesStoredOnDisk()
long	getCommTimer()
long	getComputeAllTimer()
double	getGraphPercentageInMemory()
long	getSuperstepTimer()
long	getTimeToFirstMsg()
long	getWaitRequestsTimer()
WorkerSuperstepMetrics	print(long superstep, PrintStream out) Human readable dump of metrics stored here.
void	readFields(DataInput dataInput)
WorkerSuperstepMetrics	readFromRegistry() Read metric values from global MetricsRegistry.
void	write(DataOutput dataOutput)

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkerSuperstepMetrics

public WorkerSuperstepMetrics()

Constructor

Method Detail

readFromRegistry

public WorkerSuperstepMetrics readFromRegistry()

Read metric values from global MetricsRegistry.

Returns:

this object, for chaining

print

public WorkerSuperstepMetrics print(long superstep,
                                    PrintStream out)

Human readable dump of metrics stored here.

Parameters:

superstep - long number of superstep.

out - PrintStream to write to.

Returns:

this object, for chaining

getCommTimer

public long getCommTimer()

Returns:

Communication timer

getComputeAllTimer

public long getComputeAllTimer()

Returns:

Total compute timer

getTimeToFirstMsg

public long getTimeToFirstMsg()

Returns:

timer between start time and first message flushed.

getSuperstepTimer

public long getSuperstepTimer()

Returns:

timer for superstep time

getWaitRequestsTimer

public long getWaitRequestsTimer()

Returns:

timer waiting for other workers

getBytesLoadedFromDisk

public long getBytesLoadedFromDisk()

Returns:

number of bytes loaded from disk by out-of-core mechanism (if any is used)

getBytesStoredOnDisk

public long getBytesStoredOnDisk()

Returns:

number of bytes stored on disk by out-of-core mechanism (if any is used)

getGraphPercentageInMemory

public double getGraphPercentageInMemory()

Returns:

a rough estimate of percentage of graph in memory

readFields

public void readFields(DataInput dataInput)
                throws IOException

Specified by:

readFields in interface org.apache.hadoop.io.Writable

Throws:

IOException

write

public void write(DataOutput dataOutput)
           throws IOException

Specified by:

write in interface org.apache.hadoop.io.Writable

Throws:

IOException