org.apache.giraph.examples

Class SimpleCheckpoint.SimpleCheckpointVertexWorkerContext

java.lang.Object

org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable<I,V,E>

org.apache.giraph.worker.WorkerAggregatorDelegator<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>

org.apache.giraph.worker.WorkerContext

org.apache.giraph.examples.SimpleCheckpoint.SimpleCheckpointVertexWorkerContext

All Implemented Interfaces:

AggregatorUsage, GiraphConfigurationSettable<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>, ImmutableClassesGiraphConfigurable<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>, WorkerAggregatorUsage, WorkerBroadcastUsage, WorkerGlobalCommUsage, WorkerIndexUsage<org.apache.hadoop.io.WritableComparable>, WorkerReduceUsage, org.apache.hadoop.io.Writable

Enclosing class:

SimpleCheckpoint

public static class SimpleCheckpoint.SimpleCheckpointVertexWorkerContext
extends WorkerContext

Worker context associated with SimpleCheckpoint.

Field Summary

Fields

Modifier and Type	Field and Description
static String	FAULT_FILE Filename to indicate whether a fault was found

Constructor Summary

Constructors

Constructor and Description
SimpleCheckpointVertexWorkerContext()

Method Summary

Modifier and Type	Method and Description
boolean	getEnableFault()
static long	getFinalSum()
int	getSupersteps()
void	postApplication() Finalize the WorkerContext.
void	postSuperstep() Execute user code.
void	preApplication() Initialize the WorkerContext.
void	preSuperstep() Execute user code.

Methods inherited from class org.apache.giraph.worker.WorkerContext

getAndClearMessagesFromOtherWorkers, getContext, getMyWorkerIndex, getSuperstep, getTotalNumEdges, getTotalNumVertices, getWorkerCount, getWorkerForVertex, logToCommandLine, readFields, sendMessageToWorker, setGraphState, setupSuperstep, write

Methods inherited from class org.apache.giraph.worker.WorkerAggregatorDelegator

aggregate, getAggregatedValue, getBroadcast, reduce, reduceMerge, setWorkerGlobalCommUsage

Methods inherited from class org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable

getConf, setConf

Methods inherited from class java.lang.Object

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

Field Detail

FAULT_FILE

public static final String FAULT_FILE

Filename to indicate whether a fault was found

See Also:

Constant Field Values

Constructor Detail

SimpleCheckpointVertexWorkerContext

public SimpleCheckpointVertexWorkerContext()

Method Detail

getFinalSum

public static long getFinalSum()

preApplication

public void preApplication()
                    throws InstantiationException,
                           IllegalAccessException

Description copied from class: WorkerContext

Initialize the WorkerContext. This method is executed once on each Worker before the first superstep starts.

Specified by:

preApplication in class WorkerContext

Throws:

InstantiationException - Expected instantiation in this method.

IllegalAccessException - Thrown for getting the class

postApplication

public void postApplication()

Description copied from class: WorkerContext

Finalize the WorkerContext. This method is executed once on each Worker after the last superstep ends.

Specified by:

postApplication in class WorkerContext

preSuperstep

public void preSuperstep()

Description copied from class: WorkerContext

Execute user code. This method is executed once on each Worker before each superstep starts.

Specified by:

preSuperstep in class WorkerContext

postSuperstep

public void postSuperstep()

Description copied from class: WorkerContext

Execute user code. This method is executed once on each Worker after each superstep ends.

Specified by:

postSuperstep in class WorkerContext

getSupersteps

public int getSupersteps()

getEnableFault

public boolean getEnableFault()