public class GraknComputerImpl extends Object implements GraknComputer
Graph Computer Used For Analytics Algorithms
Wraps a Tinkerpop GraphComputer which enables the execution of pregel programs.
These programs are defined either via a MapReduce or a VertexProgram.
A VertexProgram is a computation executed on each vertex in parallel.
Vertices communicate with each other through message passing.
MapReduce processed the vertices in a parallel manner by aggregating values emitted by vertices.
MapReduce can be executed alone or used to collect the results after executing a VertexProgram.
| Constructor and Description |
|---|
GraknComputerImpl(org.apache.tinkerpop.gremlin.structure.Graph graph) |
| Modifier and Type | Method and Description |
|---|---|
org.apache.tinkerpop.gremlin.process.computer.ComputerResult |
compute(org.apache.tinkerpop.gremlin.process.computer.MapReduce mapReduce)
Execute the given map reduce job using a graph computer.
|
org.apache.tinkerpop.gremlin.process.computer.ComputerResult |
compute(org.apache.tinkerpop.gremlin.process.computer.VertexProgram program,
org.apache.tinkerpop.gremlin.process.computer.MapReduce... mapReduces)
Execute the given vertex program using a graph computer.
|
protected org.apache.tinkerpop.gremlin.process.computer.GraphComputer |
getGraphComputer() |
protected Class<? extends org.apache.tinkerpop.gremlin.process.computer.GraphComputer> |
getGraphComputerClass(String graphComputerType) |
void |
killJobs()
Kill all the jobs the graph computer has
|
public GraknComputerImpl(org.apache.tinkerpop.gremlin.structure.Graph graph)
public org.apache.tinkerpop.gremlin.process.computer.ComputerResult compute(org.apache.tinkerpop.gremlin.process.computer.VertexProgram program,
org.apache.tinkerpop.gremlin.process.computer.MapReduce... mapReduces)
GraknComputercompute in interface GraknComputerprogram - the vertex programmapReduces - a list of mapReduce jobComputerResultpublic org.apache.tinkerpop.gremlin.process.computer.ComputerResult compute(org.apache.tinkerpop.gremlin.process.computer.MapReduce mapReduce)
GraknComputercompute in interface GraknComputermapReduce - the map reduce jobComputerResultpublic void killJobs()
GraknComputerkillJobs in interface GraknComputerprotected Class<? extends org.apache.tinkerpop.gremlin.process.computer.GraphComputer> getGraphComputerClass(String graphComputerType)
protected org.apache.tinkerpop.gremlin.process.computer.GraphComputer getGraphComputer()
Copyright © 2017 Grakn Labs Ltd. All rights reserved.