org.apache.tinkerpop.gremlin.process.computer

Class GraphComputerTest.BadGraphComputer

java.lang.Object

org.apache.tinkerpop.gremlin.process.computer.GraphComputerTest.BadGraphComputer

All Implemented Interfaces:

GraphComputer

Enclosing class:

GraphComputerTest

public static class GraphComputerTest.BadGraphComputer
extends Object
implements GraphComputer

Nested Class Summary

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

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

Constructor Summary

Constructors

Constructor and Description
BadGraphComputer()

Method Summary

Modifier and Type	Method and Description
GraphComputer	configure(String key, Object value) Set an arbitrary configuration key/value for the underlying org.apache.commons.configuration.Configuration in the GraphComputer.
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.
Future<ComputerResult>	submit() Submit the VertexProgram and the set of MapReduce jobs for execution by the GraphComputer.
GraphComputer	workers(int workers) Set the desired number of workers to execute the VertexProgram and MapReduce jobs.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.tinkerpop.gremlin.process.computer.GraphComputer

features

Constructor Detail

BadGraphComputer

public BadGraphComputer()

Method Detail

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

workers

public GraphComputer workers(int workers)

Description copied from interface: GraphComputer

Set the desired number of workers to execute the VertexProgram and MapReduce jobs. This is a recommendation to the underlying GraphComputer implementation and is allowed to deviate accordingly by the implementation.

Specified by:

workers in interface GraphComputer

Parameters:

workers - the number of workers to execute the submission

Returns:

the updated GraphComputer with newly set worker count

configure

public GraphComputer configure(String key,
                               Object value)

Description copied from interface: GraphComputer

Set an arbitrary configuration key/value for the underlying org.apache.commons.configuration.Configuration in the GraphComputer. Typically, the other fluent methods in GraphComputer should be used to configure the computation. However, for some custom configuration in the underlying engine, this method should be used. Different GraphComputer implementations will have different key/values and thus, parameters placed here are generally not universal to all GraphComputer implementations. The default implementation simply does nothing and returns the GraphComputer unchanged.

Specified by:

configure in interface GraphComputer

Parameters:

key - the key of the configuration

value - the value of the configuration

Returns:

the updated GraphComputer with newly set key/value configuration

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.