org.apache.giraph

Class TestCheckpointing

java.lang.Object

org.apache.giraph.BspCase

org.apache.giraph.TestCheckpointing

All Implemented Interfaces:

org.apache.zookeeper.Watcher

public class TestCheckpointing
extends BspCase

Tests that worker context and master computation are properly saved and loaded back at checkpoint.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestCheckpointing.CheckpointComputation Actual computation.
static class	TestCheckpointing.CheckpointVertexMasterCompute Master compute
static class	TestCheckpointing.CheckpointVertexWorkerContext Worker context associated.

Nested classes/interfaces inherited from interface org.apache.zookeeper.Watcher

org.apache.zookeeper.Watcher.Event

Field Summary

Fields

Modifier and Type	Field and Description
static String	TEST_JOB_ID ID to be used with test job

Fields inherited from class org.apache.giraph.BspCase

READER_VERTICES_OPT

Constructor Summary

Constructors

Constructor and Description
TestCheckpointing() Create the test case

Method Summary

Modifier and Type	Method and Description
void	testAsyncMessageStoreCheckpoint()
void	testBspCheckpoint()
void	testBspCheckpoint(boolean useAsyncMessageStore)
void	testManualCheckpoint()
void	testManualCheckpointAtTheBeginning()

Methods inherited from class org.apache.giraph.BspCase

getCallingMethodName, getNumResults, getNumWorkers, getSinglePartFileStatus, getTempPath, getZooKeeperList, prepareJob, prepareJob, process, removeAndSetOutput, runningInDistributedMode, setUp, setupConfiguration, tearDown

Methods inherited from class java.lang.Object

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

Field Detail

TEST_JOB_ID

public static final String TEST_JOB_ID

ID to be used with test job

See Also:

Constant Field Values

Constructor Detail

TestCheckpointing

public TestCheckpointing()

Create the test case

Method Detail

testBspCheckpoint

public void testBspCheckpoint()
                       throws InterruptedException,
                              IOException,
                              ClassNotFoundException

Throws:

InterruptedException

IOException

ClassNotFoundException

testAsyncMessageStoreCheckpoint

public void testAsyncMessageStoreCheckpoint()
                                     throws InterruptedException,
                                            IOException,
                                            ClassNotFoundException

Throws:

InterruptedException

IOException

ClassNotFoundException

testBspCheckpoint

public void testBspCheckpoint(boolean useAsyncMessageStore)
                       throws IOException,
                              InterruptedException,
                              ClassNotFoundException

Throws:

IOException

InterruptedException

ClassNotFoundException

testManualCheckpointAtTheBeginning

public void testManualCheckpointAtTheBeginning()
                                        throws InterruptedException,
                                               IOException,
                                               ClassNotFoundException

Throws:

InterruptedException

IOException

ClassNotFoundException

testManualCheckpoint

public void testManualCheckpoint()
                          throws InterruptedException,
                                 IOException,
                                 ClassNotFoundException

Throws:

InterruptedException

IOException

ClassNotFoundException