org.apache.tinkerpop.gremlin.hadoop.process.computer.giraph

Class GiraphGraphComputer

java.lang.Object

org.apache.hadoop.conf.Configured

org.apache.tinkerpop.gremlin.hadoop.process.computer.giraph.GiraphGraphComputer

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.util.Tool, GraphComputer

public class GiraphGraphComputer
extends org.apache.hadoop.conf.Configured
implements GraphComputer, org.apache.hadoop.util.Tool

Author:

Marko A. Rodriguez (http://markorodriguez.com)

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.tinkerpop.gremlin.process.computer.GraphComputer

GraphComputer.Exceptions, GraphComputer.Features, GraphComputer.Isolation, GraphComputer.Persist, GraphComputer.ResultGraph

Field Summary

Fields

Modifier and Type	Field and Description
protected GiraphConfiguration	giraphConfiguration
protected HadoopGraph	hadoopGraph
static Logger	LOGGER

Constructor Summary

Constructors

Constructor and Description
GiraphGraphComputer(HadoopGraph hadoopGraph)

Method Summary

Modifier and Type	Method and Description
GraphComputer.Features	features()
GraphComputer	isolation(GraphComputer.Isolation isolation) Set the GraphComputer.Isolation of the computation.
static void	main(String[] args)
GraphComputer	mapReduce(MapReduce mapReduce) Add a MapReduce job to the set of MapReduce jobs to be executed by the GraphComputer.
GraphComputer	persist(GraphComputer.Persist persist) Set the GraphComputer.Persist level of the computation.
GraphComputer	program(VertexProgram vertexProgram) Set the VertexProgram to be executed by the GraphComputer.
GraphComputer	result(GraphComputer.ResultGraph resultGraph) Set the GraphComputer.ResultGraph of the computation.
int	run(String[] args)
Future<ComputerResult>	submit() Submit the VertexProgram and the set of MapReduce jobs for execution by the GraphComputer.
String	toString()

Methods inherited from class org.apache.hadoop.conf.Configured

getConf, setConf

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.conf.Configurable

getConf, setConf

Field Detail

LOGGER

public static final Logger LOGGER

hadoopGraph

protected final HadoopGraph hadoopGraph

giraphConfiguration

protected GiraphConfiguration giraphConfiguration

Constructor Detail

GiraphGraphComputer

public GiraphGraphComputer(HadoopGraph hadoopGraph)

Method Detail

isolation

public GraphComputer isolation(GraphComputer.Isolation isolation)

Description copied from interface: GraphComputer

Set the GraphComputer.Isolation of the computation.

Specified by:

isolation in interface GraphComputer

Parameters:

isolation - the isolation of the computation

Returns:

the updated GraphComputer with newly set isolation

result

public GraphComputer result(GraphComputer.ResultGraph resultGraph)

Description copied from interface: GraphComputer

Set the GraphComputer.ResultGraph of the computation. If this is not set explicitly by the user, then the VertexProgram can choose the most efficient result for its intended use. If there is no declared vertex program, then the GraphComputer defaults to GraphComputer.ResultGraph.ORIGINAL.

Specified by:

result in interface GraphComputer

Parameters:

resultGraph - the type of graph to be returned by ComputerResult.graph()

Returns:

the updated GraphComputer with newly set result graph

persist

public GraphComputer persist(GraphComputer.Persist persist)

Description copied from interface: GraphComputer

Set the GraphComputer.Persist level of the computation. If this is not set explicitly by the user, then the VertexProgram can choose the most efficient persist for the its intended use. If there is no declared vertex program, then the GraphComputer defaults to GraphComputer.Persist.NOTHING.

Specified by:

persist in interface GraphComputer

Parameters:

persist - the persistence level of the resultant computation

Returns:

the updated GraphComputer with newly set persist

program

public GraphComputer program(VertexProgram vertexProgram)

Description copied from interface: GraphComputer

Set the VertexProgram to be executed by the GraphComputer. There can only be one VertexProgram for the GraphComputer.

Specified by:

program in interface GraphComputer

Parameters:

vertexProgram - the VertexProgram to be executed

Returns:

the updated GraphComputer with newly set VertexProgram

mapReduce

public GraphComputer mapReduce(MapReduce mapReduce)

Description copied from interface: GraphComputer

Add a MapReduce job to the set of MapReduce jobs to be executed by the GraphComputer. There can be any number of MapReduce jobs.

Specified by:

mapReduce in interface GraphComputer

Parameters:

mapReduce - the MapReduce job to add to the computation

Returns:

the updated GraphComputer with newly added MapReduce job

toString

public String toString()

Overrides:

toString in class Object

submit

public Future<ComputerResult> submit()

Description copied from interface: GraphComputer

Submit the VertexProgram and the set of MapReduce jobs for execution by the GraphComputer.

Specified by:

submit in interface GraphComputer

Returns:

a Future denoting a reference to the asynchronous computation and where to get the DefaultComputerResult when its is complete.

run

public int run(String[] args)

Specified by:

run in interface org.apache.hadoop.util.Tool

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception

features

public GraphComputer.Features features()

Specified by:

features in interface GraphComputer