| Modifier and Type | Class and Description | 
|---|---|
class  | 
GiraphMemory  | 
class  | 
PassThroughMemory  | 
| 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. 
 | 
void | 
GraphComputerTest.VertexProgramF.execute(Vertex vertex,
       Messenger<Object> messenger,
       Memory memory)  | 
void | 
GraphComputerTest.VertexProgramB.execute(Vertex vertex,
       Messenger messenger,
       Memory memory)  | 
void | 
GraphComputerTest.VertexProgramC.execute(Vertex vertex,
       Messenger messenger,
       Memory memory)  | 
void | 
GraphComputerTest.VertexProgramD.execute(Vertex vertex,
       Messenger messenger,
       Memory memory)  | 
void | 
GraphComputerTest.VertexProgramE.execute(Vertex vertex,
       Messenger messenger,
       Memory memory)  | 
void | 
GraphComputerTest.VertexProgramA.execute(Vertex vertex,
       Messenger messenger,
       Memory memory)  | 
void | 
GraphComputerTest.VertexProgramG.execute(Vertex vertex,
       Messenger messenger,
       Memory memory)  | 
void | 
GraphComputerTest.VertexProgramH.execute(Vertex vertex,
       Messenger messenger,
       Memory memory)  | 
void | 
GraphComputerTest.VertexProgramI.execute(Vertex vertex,
       Messenger messenger,
       Memory memory)  | 
void | 
GraphComputerTest.VertexProgramJ.execute(Vertex vertex,
       Messenger messenger,
       Memory memory)  | 
void | 
GraphComputerTest.VertexProgramK.execute(Vertex vertex,
       Messenger messenger,
       Memory memory)  | 
void | 
GraphComputerTest.VertexProgramL.execute(Vertex vertex,
       Messenger messenger,
       Memory memory)  | 
void | 
GraphComputerTest.VertexProgramM.execute(Vertex vertex,
       Messenger messenger,
       Memory memory)  | 
Set<MessageScope> | 
VertexProgram.getMessageScopes(Memory memory)
This method returns all the  
MessageScope possibilities for a particular iteration of the vertex program. | 
Set<MessageScope> | 
GraphComputerTest.VertexProgramB.getMessageScopes(Memory memory)  | 
Set<MessageScope> | 
GraphComputerTest.VertexProgramC.getMessageScopes(Memory memory)  | 
Set<MessageScope> | 
GraphComputerTest.VertexProgramD.getMessageScopes(Memory memory)  | 
Set<MessageScope> | 
GraphComputerTest.VertexProgramE.getMessageScopes(Memory memory)  | 
Set<MessageScope> | 
GraphComputerTest.VertexProgramA.getMessageScopes(Memory memory)  | 
Set<MessageScope> | 
GraphComputerTest.VertexProgramF.getMessageScopes(Memory memory)  | 
Set<MessageScope> | 
GraphComputerTest.VertexProgramG.getMessageScopes(Memory memory)  | 
Set<MessageScope> | 
GraphComputerTest.VertexProgramH.getMessageScopes(Memory memory)  | 
Set<MessageScope> | 
GraphComputerTest.VertexProgramI.getMessageScopes(Memory memory)  | 
Set<MessageScope> | 
GraphComputerTest.VertexProgramJ.getMessageScopes(Memory memory)  | 
Set<MessageScope> | 
GraphComputerTest.VertexProgramK.getMessageScopes(Memory memory)  | 
Set<MessageScope> | 
GraphComputerTest.VertexProgramL.getMessageScopes(Memory memory)  | 
Set<MessageScope> | 
GraphComputerTest.VertexProgramM.getMessageScopes(Memory memory)  | 
void | 
VertexProgram.setup(Memory memory)
The method is called at the beginning of the computation. 
 | 
void | 
GraphComputerTest.VertexProgramB.setup(Memory memory)  | 
void | 
GraphComputerTest.VertexProgramC.setup(Memory memory)  | 
void | 
GraphComputerTest.VertexProgramD.setup(Memory memory)  | 
void | 
GraphComputerTest.VertexProgramE.setup(Memory memory)  | 
void | 
GraphComputerTest.VertexProgramA.setup(Memory memory)  | 
void | 
GraphComputerTest.VertexProgramF.setup(Memory memory)  | 
void | 
GraphComputerTest.VertexProgramG.setup(Memory memory)  | 
void | 
GraphComputerTest.VertexProgramH.setup(Memory memory)  | 
void | 
GraphComputerTest.VertexProgramI.setup(Memory memory)  | 
void | 
GraphComputerTest.VertexProgramJ.setup(Memory memory)  | 
void | 
GraphComputerTest.VertexProgramK.setup(Memory memory)  | 
void | 
GraphComputerTest.VertexProgramL.setup(Memory memory)  | 
void | 
GraphComputerTest.VertexProgramM.setup(Memory memory)  | 
boolean | 
VertexProgram.terminate(Memory memory)
The method is called at the end of each iteration to determine if the computation is complete. 
 | 
boolean | 
GraphComputerTest.VertexProgramB.terminate(Memory memory)  | 
boolean | 
GraphComputerTest.VertexProgramC.terminate(Memory memory)  | 
boolean | 
GraphComputerTest.VertexProgramD.terminate(Memory memory)  | 
boolean | 
GraphComputerTest.VertexProgramE.terminate(Memory memory)  | 
boolean | 
GraphComputerTest.VertexProgramA.terminate(Memory memory)  | 
boolean | 
GraphComputerTest.VertexProgramF.terminate(Memory memory)  | 
boolean | 
GraphComputerTest.VertexProgramG.terminate(Memory memory)  | 
boolean | 
GraphComputerTest.VertexProgramH.terminate(Memory memory)  | 
boolean | 
GraphComputerTest.VertexProgramI.terminate(Memory memory)  | 
boolean | 
GraphComputerTest.VertexProgramJ.terminate(Memory memory)  | 
boolean | 
GraphComputerTest.VertexProgramK.terminate(Memory memory)  | 
boolean | 
GraphComputerTest.VertexProgramL.terminate(Memory memory)  | 
boolean | 
GraphComputerTest.VertexProgramM.terminate(Memory memory)  | 
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. 
 | 
void | 
GraphComputerTest.VertexProgramJ.workerIterationEnd(Memory memory)  | 
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. 
 | 
void | 
GraphComputerTest.VertexProgramJ.workerIterationStart(Memory memory)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
BulkDumperVertexProgram.execute(Vertex sourceVertex,
       Messenger<Tuple> messenger,
       Memory memory)  | 
Set<MessageScope> | 
BulkDumperVertexProgram.getMessageScopes(Memory memory)  | 
void | 
BulkDumperVertexProgram.setup(Memory memory)  | 
boolean | 
BulkDumperVertexProgram.terminate(Memory memory)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
BulkLoaderVertexProgram.execute(Vertex sourceVertex,
       Messenger<Tuple> messenger,
       Memory memory)  | 
Set<MessageScope> | 
BulkLoaderVertexProgram.getMessageScopes(Memory memory)  | 
void | 
BulkLoaderVertexProgram.setup(Memory memory)  | 
boolean | 
BulkLoaderVertexProgram.terminate(Memory memory)  | 
void | 
BulkLoaderVertexProgram.workerIterationEnd(Memory memory)  | 
void | 
BulkLoaderVertexProgram.workerIterationStart(Memory memory)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
PeerPressureVertexProgram.execute(Vertex vertex,
       Messenger<<any>> 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<TraverserSet<Object>> messenger,
       Memory memory)  | 
Set<MessageScope> | 
TraversalVertexProgram.getMessageScopes(Memory memory)  | 
static void | 
MemoryTraversalSideEffects.setMemorySideEffects(Traversal.Admin<?,?> traversal,
                    Memory memory,
                    ProgramPhase phase)  | 
void | 
TraversalVertexProgram.setup(Memory memory)  | 
boolean | 
TraversalVertexProgram.terminate(Memory memory)  | 
| Modifier and Type | Method and Description | 
|---|---|
VertexProgram | 
VertexComputing.generateProgram(Graph graph,
               Memory memory)
Generate the  
VertexProgram. | 
| Modifier and Type | Method and Description | 
|---|---|
VertexProgram | 
ProgramVertexProgramStep.generateProgram(Graph graph,
               Memory memory)  | 
TraversalVertexProgram | 
TraversalVertexProgramStep.generateProgram(Graph graph,
               Memory memory)  | 
PeerPressureVertexProgram | 
PeerPressureVertexProgramStep.generateProgram(Graph graph,
               Memory memory)  | 
PageRankVertexProgram | 
PageRankVertexProgramStep.generateProgram(Graph graph,
               Memory memory)  | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
VertexProgramInterceptor<V extends VertexProgram,G,M extends Memory>  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
EmptyMemory  | 
class  | 
ImmutableMemory  | 
class  | 
MapMemory  | 
| Modifier and Type | Field and Description | 
|---|---|
protected Memory | 
DefaultComputerResult.memory  | 
| Modifier and Type | Method and Description | 
|---|---|
Memory | 
EmptyMemory.asImmutable()  | 
Memory | 
DefaultComputerResult.memory()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
VertexProgramPool.workerIterationEnd(Memory memory)  | 
void | 
VertexProgramPool.workerIterationStart(Memory memory)  | 
| Constructor and Description | 
|---|
DefaultComputerResult(Graph graph,
                     Memory memory)  | 
ImmutableMemory(Memory baseMemory)  | 
MapMemory(Memory otherMemory)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ProgramTest.TestProgram.execute(Vertex vertex,
       Messenger messenger,
       Memory memory)  | 
Set<MessageScope> | 
ProgramTest.TestProgram.getMessageScopes(Memory memory)  | 
void | 
ProgramTest.TestProgram.setup(Memory memory)  | 
boolean | 
ProgramTest.TestProgram.terminate(Memory memory)  | 
void | 
ProgramTest.TestProgram.workerIterationEnd(Memory memory)  | 
void | 
ProgramTest.TestProgram.workerIterationStart(Memory memory)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
SparkMemory  | 
| Modifier and Type | Method and Description | 
|---|---|
static String | 
StringFactory.memoryString(Memory memory)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
TinkerMemory  | 
class  | 
TinkerWorkerMemory  | 
Copyright © 2013–2017 Apache Software Foundation. All rights reserved.