Interface | Description |
---|---|
ComputerResult |
The result of the
GraphComputer 's computation. |
GraphComputer |
The
GraphComputer is responsible for the execution of a VertexProgram and then a set of MapReduce jobs
over the vertices in the Graph . |
GraphComputer.Features | |
MapReduce<MK,MV,RK,RV,R> |
A MapReduce is composed of map(), combine(), and reduce() stages.
|
MapReduce.MapEmitter<K,V> |
The MapEmitter is used to emit key/value pairs from the map() stage of the MapReduce job.
|
MapReduce.ReduceEmitter<OK,OV> |
The ReduceEmitter is used to emit key/value pairs from the combine() and reduce() stages of the MapReduce job.
|
Memory |
The Memory of a
GraphComputer is a global data structure where by vertices can communicate information with one another. |
Memory.Admin |
The Admin interface is used by the
GraphComputer to update the Memory. |
MessageCombiner<M> |
A MessageCombiner allows two messages in route to the same vertex to be aggregated into a single message.
|
Messenger<M> |
The
Messenger serves as the routing system for messages between vertices. |
VertexProgram<M> |
A
VertexProgram represents one component of a distributed graph computation. |
VertexProgram.Builder | |
VertexProgram.Features |
Enum | Description |
---|---|
GraphComputer.Persist | |
GraphComputer.ResultGraph | |
GraphFilter.Legal |
A enum denoting whether a particular result will be allowed or not.
|
MapReduce.Stage |
MapReduce is composed of three stages: map, combine, and reduce.
|
ProgramPhase |
Copyright © 2013–2018 Apache Software Foundation. All rights reserved.