org.apache.giraph.aggregators

Class TestAggregatorsHandling

java.lang.Object

org.apache.giraph.BspCase

org.apache.giraph.aggregators.TestAggregatorsHandling

All Implemented Interfaces:

org.apache.zookeeper.Watcher

public class TestAggregatorsHandling
extends BspCase

Tests if aggregators are handled on a proper way

Nested Class Summary

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

org.apache.zookeeper.Watcher.Event

Field Summary

Fields inherited from class org.apache.giraph.BspCase

READER_VERTICES_OPT

Constructor Summary

Constructors

Constructor and Description
TestAggregatorsHandling()

Method Summary

Modifier and Type	Method and Description
void	testAggregatorsCheckpointing() Test if aggregators are are handled properly when restarting from a checkpoint
void	testAggregatorsHandling() Tests if aggregators are handled on a proper way during supersteps

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

Constructor Detail

TestAggregatorsHandling

public TestAggregatorsHandling()

Method Detail

testAggregatorsHandling

public void testAggregatorsHandling()
                             throws IOException,
                                    ClassNotFoundException,
                                    InterruptedException

Tests if aggregators are handled on a proper way during supersteps

Throws:

IOException

ClassNotFoundException

InterruptedException

testAggregatorsCheckpointing

public void testAggregatorsCheckpointing()
                                  throws ClassNotFoundException,
                                         IOException,
                                         InterruptedException

Test if aggregators are are handled properly when restarting from a checkpoint

Throws:

ClassNotFoundException

IOException

InterruptedException