public final class GraknSparkComputer
extends org.apache.tinkerpop.gremlin.hadoop.process.computer.AbstractHadoopGraphComputer
This is a modified version of Spark Computer. We change its behaviour so it can won't destroy the rdd after every job.
org.apache.tinkerpop.gremlin.hadoop.process.computer.AbstractHadoopGraphComputer.Featuresorg.apache.tinkerpop.gremlin.process.computer.GraphComputer.Exceptions, org.apache.tinkerpop.gremlin.process.computer.GraphComputer.Persist, org.apache.tinkerpop.gremlin.process.computer.GraphComputer.ResultGraph| Constructor and Description |
|---|
GraknSparkComputer(org.apache.tinkerpop.gremlin.hadoop.structure.HadoopGraph hadoopGraph) |
| Modifier and Type | Method and Description |
|---|---|
void |
cancelJobs() |
static void |
clear() |
static void |
main(String[] args) |
static void |
refresh() |
Future<org.apache.tinkerpop.gremlin.process.computer.ComputerResult> |
submit() |
org.apache.tinkerpop.gremlin.process.computer.GraphComputer |
workers(int workers) |
features, mapReduce, persist, program, result, toString, validateStatePriorToExecutionpublic GraknSparkComputer(org.apache.tinkerpop.gremlin.hadoop.structure.HadoopGraph hadoopGraph)
public org.apache.tinkerpop.gremlin.process.computer.GraphComputer workers(int workers)
workers in interface org.apache.tinkerpop.gremlin.process.computer.GraphComputerworkers in class org.apache.tinkerpop.gremlin.hadoop.process.computer.AbstractHadoopGraphComputerpublic Future<org.apache.tinkerpop.gremlin.process.computer.ComputerResult> submit()
public void cancelJobs()
public static void refresh()
public static void clear()
Copyright © 2017 Grakn Labs Ltd. All rights reserved.