org.apache.giraph.block_app.test_setup

Class TestGraphUtils

java.lang.Object

org.apache.giraph.block_app.test_setup.TestGraphUtils

public class TestGraphUtils
extends Object

Utility functions for running TestGraph unit tests.

Field Summary

Fields

Modifier and Type	Field and Description
static BooleanConfOption	USE_FULL_GIRAPH_ENV_IN_TESTS modify locally for running full Digraph tests from IDE

Method Summary

Modifier and Type	Method and Description
static BulkConfigurator	chainConfigurators(BulkConfigurator... configurators) Chain execution of multiple BulkConfigurators into one.
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> TestGraphModifier<I,V,E>	chainModifiers(TestGraphModifier<I,V,E>... graphModifiers) Chain execution of multiple TestGraphModifier into one.
static Supplier<org.apache.hadoop.io.DoubleWritable>	doubleSupplier(double value)
static Supplier<org.apache.hadoop.io.NullWritable>	nullSupplier()
static <I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable,V extends org.apache.hadoop.io.Writable> void	runTest(NumericTestGraph<I,V,E> graph, TestGraphChecker<? super I,? super V,? super E> graphChecker) Base of runTest.
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> void	runTest(TestGraphModifier<? super I,? super V,? super E> graphInitializer, TestGraphChecker<? super I,? super V,? super E> graphChecker, BulkConfigurator configurator) Creates configuration using configurator, initializes the graph using graphInitializer, and checks it via graphChecker.
static <I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable,V extends org.apache.hadoop.io.Writable> void	runTest(TestGraphModifier<? super I,? super V,? super E> graphInitializer, TestGraphChecker<? super I,? super V,? super E> graphChecker, GiraphConfiguration conf) Uses provided configuration, initializes the graph using graphInitializer, and checks it via graphChecker.
static void	setTestRepeatTimes(int testRepeatTimes)

Methods inherited from class java.lang.Object

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

Field Detail

USE_FULL_GIRAPH_ENV_IN_TESTS

public static final BooleanConfOption USE_FULL_GIRAPH_ENV_IN_TESTS

modify locally for running full Digraph tests from IDE

Method Detail

runTest

public static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> void runTest(TestGraphModifier<? super I,? super V,? super E> graphInitializer,
                                                                                                                                                               TestGraphChecker<? super I,? super V,? super E> graphChecker,
                                                                                                                                                               BulkConfigurator configurator)
                                                                                                                                                        throws Exception

Creates configuration using configurator, initializes the graph using graphInitializer, and checks it via graphChecker. Supports using TEST_REPEAT_TIMES for running the same test multiple times.

Throws:

Exception

runTest

public static <I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable,V extends org.apache.hadoop.io.Writable> void runTest(TestGraphModifier<? super I,? super V,? super E> graphInitializer,
                                                                                                                                                               TestGraphChecker<? super I,? super V,? super E> graphChecker,
                                                                                                                                                               GiraphConfiguration conf)
                                                                                                                                                        throws Exception

Uses provided configuration, initializes the graph using graphInitializer, and checks it via graphChecker.

Throws:

Exception

runTest

public static <I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable,V extends org.apache.hadoop.io.Writable> void runTest(NumericTestGraph<I,V,E> graph,
                                                                                                                                                               TestGraphChecker<? super I,? super V,? super E> graphChecker)
                                                                                                                                                        throws Exception

Base of runTest. Takes a created graph, a graph-checker and conf and runs the test.

Throws:

Exception

chainModifiers

@SafeVarargs
public static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> TestGraphModifier<I,V,E> chainModifiers(TestGraphModifier<I,V,E>... graphModifiers)

Chain execution of multiple TestGraphModifier into one.

chainConfigurators

public static BulkConfigurator chainConfigurators(BulkConfigurator... configurators)

Chain execution of multiple BulkConfigurators into one. Order might matter, if they are setting the same fields. (later one will override what previous one already set).

doubleSupplier

public static Supplier<org.apache.hadoop.io.DoubleWritable> doubleSupplier(double value)

nullSupplier

public static Supplier<org.apache.hadoop.io.NullWritable> nullSupplier()

setTestRepeatTimes

public static void setTestRepeatTimes(int testRepeatTimes)