org.apache.giraph.block_app.framework.api.local

Class LocalBlockRunner

java.lang.Object

org.apache.giraph.block_app.framework.api.local.LocalBlockRunner

public class LocalBlockRunner
extends Object

Local in-memory Block application job runner. Implementation should be faster then using InternalVertexRunner. Useful for fast testing.

Field Summary

Fields

Modifier and Type	Field and Description
static IntConfOption	NUM_PARTITIONS Number of vertex partitions
static IntConfOption	NUM_THREADS Number of threads to use
static BooleanConfOption	RUN_ALL_CHECKS Whether to run all supported checks.
static BooleanConfOption	SERIALIZE_MASTER

Method Summary

Modifier and Type	Method and Description
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> void	runApp(TestGraph<I,V,E> graph) Run Block Application specified within the conf, on a given graph, locally, in-memory.
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> TestGraph<I,V,E>	runApp(TestGraph<I,V,E> graph, boolean useFullDigraphTests) Run Block Application specified within the conf, on a given graph, locally, in-memory.
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> void	runAppWithVertexOutput(TestGraph<I,V,E> graph, SimpleVertexWriter<I,V,E> vertexSaver) Run Block Application specified within the conf, on a given graph, locally, in-memory, with a given vertexSaver.
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> void	runBlock(TestGraph<I,V,E> graph, Block block, Object executionStage) Run Block from a specified execution stage on a given graph, locally, in-memory.
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> void	runBlockWithVertexOutput(Block block, Object executionStage, TestGraph<I,V,E> graph, SimpleVertexWriter<I,V,E> vertexSaver) Run Block from a specified execution stage on a given graph, locally, in-memory, with a given vertexSaver.

Methods inherited from class java.lang.Object

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

Field Detail

NUM_THREADS

public static final IntConfOption NUM_THREADS

Number of threads to use

NUM_PARTITIONS

public static final IntConfOption NUM_PARTITIONS

Number of vertex partitions

RUN_ALL_CHECKS

public static final BooleanConfOption RUN_ALL_CHECKS

Whether to run all supported checks. Disable if you are running this not within a unit test, and on a large graph, where performance matters.

SERIALIZE_MASTER

public static final BooleanConfOption SERIALIZE_MASTER

Method Detail

runApp

public static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> TestGraph<I,V,E> runApp(TestGraph<I,V,E> graph,
                                                                                                                                                                          boolean useFullDigraphTests)
                                                                                                                                                                   throws Exception

Run Block Application specified within the conf, on a given graph, locally, in-memory. With a boolean flag, you can switch between LocalBlockRunner and InternalVertexRunner implementations of local in-memory computation.

Throws:

Exception

runApp

public static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> void runApp(TestGraph<I,V,E> graph)

Run Block Application specified within the conf, on a given graph, locally, in-memory.

runBlock

public static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> void runBlock(TestGraph<I,V,E> graph,
                                                                                                                                                                Block block,
                                                                                                                                                                Object executionStage)

Run Block from a specified execution stage on a given graph, locally, in-memory.

runAppWithVertexOutput

public static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> void runAppWithVertexOutput(TestGraph<I,V,E> graph,
                                                                                                                                                                              SimpleVertexWriter<I,V,E> vertexSaver)

Run Block Application specified within the conf, on a given graph, locally, in-memory, with a given vertexSaver.

runBlockWithVertexOutput

public static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> void runBlockWithVertexOutput(Block block,
                                                                                                                                                                                Object executionStage,
                                                                                                                                                                                TestGraph<I,V,E> graph,
                                                                                                                                                                                SimpleVertexWriter<I,V,E> vertexSaver)

Run Block from a specified execution stage on a given graph, locally, in-memory, with a given vertexSaver.