org.apache.giraph.ooc

Class OutOfCoreIOCallable

java.lang.Object

org.apache.giraph.ooc.OutOfCoreIOCallable

All Implemented Interfaces:

Callable<Void>, ResetSuperstepMetricsObserver

public class OutOfCoreIOCallable
extends Object
implements Callable<Void>, ResetSuperstepMetricsObserver

IO threads for out-of-core mechanism.

Field Summary

Fields

Modifier and Type	Field and Description
static String	BYTES_LOAD_FROM_DISK Name of Metric for number of bytes read from disk
static String	BYTES_STORE_TO_DISK Name of Metric for number of bytes written to disk
static String	HISTOGRAM_LOAD_SIZE Name of Metric for size of loads
static String	HISTOGRAM_STORE_SIZE Name of Metric for size of stores

Constructor Summary

Constructors

Constructor and Description
OutOfCoreIOCallable(OutOfCoreEngine oocEngine, int diskId) Constructor

Method Summary

Modifier and Type	Method and Description
Void	call()
void	newSuperstep(SuperstepMetricsRegistry superstepMetrics) Starting a new superstep.

Methods inherited from class java.lang.Object

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

Field Detail

BYTES_LOAD_FROM_DISK

public static final String BYTES_LOAD_FROM_DISK

Name of Metric for number of bytes read from disk

See Also:

Constant Field Values

BYTES_STORE_TO_DISK

public static final String BYTES_STORE_TO_DISK

Name of Metric for number of bytes written to disk

See Also:

Constant Field Values

HISTOGRAM_LOAD_SIZE

public static final String HISTOGRAM_LOAD_SIZE

Name of Metric for size of loads

See Also:

Constant Field Values

HISTOGRAM_STORE_SIZE

public static final String HISTOGRAM_STORE_SIZE

Name of Metric for size of stores

See Also:

Constant Field Values

Constructor Detail

OutOfCoreIOCallable

public OutOfCoreIOCallable(OutOfCoreEngine oocEngine,
                           int diskId)

Constructor

Parameters:

oocEngine - out-of-core engine

diskId - thread id/disk id

Method Detail

call

public Void call()
          throws Exception

Specified by:

call in interface Callable<Void>

Throws:

Exception

newSuperstep

public void newSuperstep(SuperstepMetricsRegistry superstepMetrics)

Description copied from interface: ResetSuperstepMetricsObserver

Starting a new superstep. Re-initialize your metrics.

Specified by:

newSuperstep in interface ResetSuperstepMetricsObserver

Parameters:

superstepMetrics - SuperstepMetricsRegistry being used.