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

Class SparkGraphComputer

java.lang.Object

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

org.apache.tinkerpop.gremlin.hadoop.process.computer.spark.SparkGraphComputer

All Implemented Interfaces:

GraphComputer

public final class SparkGraphComputer
extends AbstractHadoopGraphComputer

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.Persist, GraphComputer.ResultGraph

Field Summary

Fields inherited from class org.apache.tinkerpop.gremlin.hadoop.process.computer.AbstractHadoopGraphComputer

executed, hadoopGraph, logger, mapReducers, persist, resultGraph, vertexProgram

Constructor Summary

Constructors

Constructor and Description
SparkGraphComputer(HadoopGraph hadoopGraph)

Method Summary

Modifier and Type	Method and Description
static void	main(String[] args)
Future<ComputerResult>	submit() Submit the VertexProgram and the set of MapReduce jobs for execution by the GraphComputer.

Methods inherited from class org.apache.tinkerpop.gremlin.hadoop.process.computer.AbstractHadoopGraphComputer

features, mapReduce, persist, program, result, toString, validateStatePriorToExecution

Methods inherited from class java.lang.Object

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

Constructor Detail

SparkGraphComputer

public SparkGraphComputer(HadoopGraph hadoopGraph)

Method Detail

submit

public Future<ComputerResult> submit()

Description copied from interface: GraphComputer

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

Returns:

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

main

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

Throws:

Exception