Package | Description |
---|---|
org.apache.giraph.block_app.framework.api.local |
Local (single machine) implementation of graph processing system API used by
Blocks Framework.
|
org.apache.giraph.block_app.test_setup |
Utilities for unit tests.
|
org.apache.giraph.io.formats |
Package of reusable library Giraph objects.
|
org.apache.giraph.utils |
Package of all generic utility classes.
|
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> |
LocalBlockRunner.runApp(TestGraph<I,V,E> graph,
boolean useFullDigraphTests)
Run Block Application specified within the conf, on a given graph,
locally, in-memory.
|
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> |
LocalBlockRunner.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> |
LocalBlockRunner.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> |
LocalBlockRunner.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> |
LocalBlockRunner.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> |
LocalBlockRunner.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.
|
Modifier and Type | Method and Description |
---|---|
TestGraph<I,V,E> |
NumericTestGraph.getTestGraph() |
Constructor and Description |
---|
NumericTestGraph(TestGraph<I,V,E> testGraph) |
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> |
InMemoryVertexOutputFormat.getOutputGraph()
Get graph containing all the vertices
|
Modifier and Type | Method and Description |
---|---|
TestGraph<I,V,E> |
TestGraph.addEdge(I vertexId,
I toVertex,
E edgeValue)
Add an edge to an existing vertex
|
TestGraph<I,V,E> |
TestGraph.addEdge(I vertexId,
Map.Entry<I,E> edgePair)
Add an edge to an existing vertex
`
|
TestGraph<I,V,E> |
TestGraph.addVertex(I id,
V value,
Map.Entry<I,E>... edges)
Add vertex with given ID
|
TestGraph<I,V,E> |
TestGraph.addVertex(Vertex<I,V,E> vertex)
Add vertex
|
static TestGraph |
InMemoryVertexInputFormat.getGraph() |
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> |
InternalVertexRunner.runWithInMemoryOutput(GiraphConfiguration conf,
TestGraph<I,V,E> graph)
Attempts to run the vertex internally in the current JVM, reading and
writing to an in-memory graph.
|
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> |
InternalVertexRunner.runWithInMemoryOutput(GiraphConfiguration conf,
TestGraph<I,V,E> graph,
File tmpDir,
String checkpointsDir)
Attempts to run the vertex internally in the current JVM, reading and
writing to an in-memory graph.
|
TestGraph<I,V,E> |
TestGraph.setVertex(I id,
V value,
Map.Entry<I,E>... edges)
Set vertex, replace if there was already a vertex with same id added
|
TestGraph<I,V,E> |
TestGraph.setVertex(Vertex<I,V,E> vertex)
Set vertex, replace if there was already a vertex with same id added
|
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> |
InternalVertexRunner.run(GiraphConfiguration conf,
TestGraph<I,V,E> graph)
Attempts to run the vertex internally in the current JVM,
reading from an in-memory graph.
|
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> |
InternalVertexRunner.run(GiraphConfiguration conf,
TestGraph<I,V,E> graph,
File tmpDir,
String checkpointsDir)
Attempts to run the vertex internally in the current JVM,
reading from an in-memory graph.
|
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> |
InternalVertexRunner.runWithInMemoryOutput(GiraphConfiguration conf,
TestGraph<I,V,E> graph)
Attempts to run the vertex internally in the current JVM, reading and
writing to an in-memory graph.
|
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> |
InternalVertexRunner.runWithInMemoryOutput(GiraphConfiguration conf,
TestGraph<I,V,E> graph,
File tmpDir,
String checkpointsDir)
Attempts to run the vertex internally in the current JVM, reading and
writing to an in-memory graph.
|
static void |
InMemoryVertexInputFormat.setGraph(TestGraph graph) |
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.