I
- Vertex id typeV
- Vertex value typeE
- Edge value typeM
- Message typepublic interface VertexReceiver<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M extends org.apache.hadoop.io.Writable> extends NonKryoWritable
Modifier and Type | Method and Description |
---|---|
void |
vertexReceive(Vertex<I,V,E> vertex,
Iterable<M> messages)
Must be defined by user to do computation on a single Vertex.
|
void vertexReceive(Vertex<I,V,E> vertex, Iterable<M> messages)
vertex
- Vertexmessages
- Messages that were sent to this vertex in the previous
superstep. Each message is only guaranteed to have
a life expectancy as long as next() is not called.Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.