org.apache.giraph.examples

Class SimpleCheckpoint

java.lang.Object

org.apache.giraph.examples.SimpleCheckpoint

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.util.Tool

public class SimpleCheckpoint
extends Object
implements org.apache.hadoop.util.Tool

An example that simply uses its id, value, and edges to compute new data every iteration to verify that checkpoint restarting works. Fault injection can also test automated checkpoint restarts.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SimpleCheckpoint.SimpleCheckpointComputation Actual computation.
static class	SimpleCheckpoint.SimpleCheckpointVertexMasterCompute Master compute associated with SimpleCheckpoint.
static class	SimpleCheckpoint.SimpleCheckpointVertexWorkerContext Worker context associated with SimpleCheckpoint.

Field Summary

Fields

Modifier and Type	Field and Description
static String	ENABLE_FAULT Should fault?
static int	FAULTING_SUPERSTEP Which superstep to cause the worker to fail
static long	FAULTING_VERTEX_ID Vertex id to fault on
static String	SUPERSTEP_COUNT Dynamically set number of supersteps

Constructor Summary

Constructors

Constructor and Description
SimpleCheckpoint()

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.conf.Configuration	getConf()
static void	main(String[] args) Executable from the command line.
int	run(String[] args)
void	setConf(org.apache.hadoop.conf.Configuration conf)

Methods inherited from class java.lang.Object

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

Field Detail

FAULTING_SUPERSTEP

public static final int FAULTING_SUPERSTEP

Which superstep to cause the worker to fail

See Also:

Constant Field Values

FAULTING_VERTEX_ID

public static final long FAULTING_VERTEX_ID

Vertex id to fault on

See Also:

Constant Field Values

SUPERSTEP_COUNT

public static final String SUPERSTEP_COUNT

Dynamically set number of supersteps

See Also:

Constant Field Values

ENABLE_FAULT

public static final String ENABLE_FAULT

Should fault?

See Also:

Constant Field Values

Constructor Detail

SimpleCheckpoint

public SimpleCheckpoint()

Method Detail

run

public int run(String[] args)
        throws Exception

Specified by:

run in interface org.apache.hadoop.util.Tool

Throws:

Exception

main

public static void main(String[] args)
                 throws Exception

Executable from the command line.

Parameters:

args - Command line args.

Throws:

Exception

getConf

public org.apache.hadoop.conf.Configuration getConf()

Specified by:

getConf in interface org.apache.hadoop.conf.Configurable

setConf

public void setConf(org.apache.hadoop.conf.Configuration conf)

Specified by:

setConf in interface org.apache.hadoop.conf.Configurable