Modifier and Type | Interface and Description |
---|---|
static interface |
Memory.Admin
The Admin interface is used by the
GraphComputer to update the Memory. |
Modifier and Type | Method and Description |
---|---|
default Memory |
Memory.Admin.asImmutable() |
Memory |
ComputerResult.memory()
Get the GraphComputer's computational sideEffects known as
Memory . |
Modifier and Type | Method and Description |
---|---|
void |
VertexProgram.execute(Vertex vertex,
Messenger<M> messenger,
Memory memory)
This method denotes the main body of the computation and is executed on each vertex in the graph.
|
Set<MessageScope> |
VertexProgram.getMessageScopes(Memory memory)
This method returns all the
MessageScope possibilities for a particular iteration of the vertex program. |
void |
VertexProgram.setup(Memory memory)
The method is called at the beginning of the computation.
|
boolean |
VertexProgram.terminate(Memory memory)
The method is called at the end of each iteration to determine if the computation is complete.
|
default void |
VertexProgram.workerIterationEnd(Memory memory)
This method is called at the end of each iteration of each "computational chunk."
The set of vertices in the graph are typically not processed with full parallelism.
|
default void |
VertexProgram.workerIterationStart(Memory memory)
This method is called at the start of each iteration of each "computational chunk."
The set of vertices in the graph are typically not processed with full parallelism.
|
Modifier and Type | Method and Description |
---|---|
void |
PeerPressureVertexProgram.execute(Vertex vertex,
Messenger<org.javatuples.Pair<Serializable,Double>> messenger,
Memory memory) |
Set<MessageScope> |
PeerPressureVertexProgram.getMessageScopes(Memory memory) |
void |
PeerPressureVertexProgram.setup(Memory memory) |
boolean |
PeerPressureVertexProgram.terminate(Memory memory) |
Modifier and Type | Method and Description |
---|---|
void |
PageRankVertexProgram.execute(Vertex vertex,
Messenger<Double> messenger,
Memory memory) |
Set<MessageScope> |
PageRankVertexProgram.getMessageScopes(Memory memory) |
void |
PageRankVertexProgram.setup(Memory memory) |
boolean |
PageRankVertexProgram.terminate(Memory memory) |
Modifier and Type | Method and Description |
---|---|
void |
TraversalVertexProgram.execute(Vertex vertex,
Messenger<org.apache.tinkerpop.gremlin.process.traversal.traverser.util.TraverserSet<?>> messenger,
Memory memory) |
Set<MessageScope> |
TraversalVertexProgram.getMessageScopes(Memory memory) |
void |
TraversalVertexProgram.setup(Memory memory) |
boolean |
TraversalVertexProgram.terminate(Memory memory) |
Copyright © 2013–2015 Apache Software Foundation. All rights reserved.