I
- Vertex index valueV
- Vertex valueE
- Edge valuepublic interface WorkerClientRequestProcessor<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
Modifier and Type | Method and Description |
---|---|
void |
addEdgeRequest(I vertexIndex,
Edge<I,E> edge)
Sends a request to the appropriate vertex range owner to add an edge
|
void |
addVertexRequest(Vertex<I,V,E> vertex)
Sends a request to the appropriate vertex range owner to add a vertex
|
void |
flush()
Flush all outgoing messages.
|
void |
removeEdgesRequest(I vertexIndex,
I destinationVertexIndex)
Sends a request to the appropriate vertex range owner to remove all edges
pointing to a given vertex.
|
void |
removeVertexRequest(I vertexIndex)
Sends a request to the appropriate vertex range owner to remove a vertex
|
long |
resetMessageBytesCount()
Get the message bytes sent during this superstep and clear them.
|
long |
resetMessageCount()
Get the messages sent during this superstep and clear them.
|
boolean |
sendEdgeRequest(I sourceVertexId,
Edge<I,E> edge)
Sends a request to the source vertex owner to add an edge.
|
void |
sendMessageRequest(I destVertexId,
org.apache.hadoop.io.Writable message)
Sends a message to destination vertex.
|
void |
sendMessageToAllRequest(Iterator<I> vertexIdIterator,
org.apache.hadoop.io.Writable message)
Sends a message to the targets in the iterator.
|
void |
sendMessageToAllRequest(Vertex<I,V,E> vertex,
org.apache.hadoop.io.Writable message)
Sends a message through all edges to all destinations.
|
void |
sendPartitionRequest(WorkerInfo workerInfo,
Partition<I,V,E> partition)
Send a partition request (no batching).
|
boolean |
sendVertexRequest(PartitionOwner partitionOwner,
Vertex<I,V,E> vertex)
Sends a vertex to the appropriate partition owner
|
void sendMessageRequest(I destVertexId, org.apache.hadoop.io.Writable message)
destVertexId
- Destination vertex id.message
- Message to send.void sendMessageToAllRequest(Vertex<I,V,E> vertex, org.apache.hadoop.io.Writable message)
vertex
- The source vertex.message
- Message to send.void sendMessageToAllRequest(Iterator<I> vertexIdIterator, org.apache.hadoop.io.Writable message)
vertexIdIterator
- The iterator of target vertex ids.message
- Message to send.boolean sendVertexRequest(PartitionOwner partitionOwner, Vertex<I,V,E> vertex)
partitionOwner
- Owner of the vertexvertex
- Vertex to sendvoid sendPartitionRequest(WorkerInfo workerInfo, Partition<I,V,E> partition)
workerInfo
- Worker to send the partition topartition
- Partition to sendvoid addEdgeRequest(I vertexIndex, Edge<I,E> edge) throws IOException
vertexIndex
- Index of the vertex to get the requestedge
- Edge to be addedIOException
boolean sendEdgeRequest(I sourceVertexId, Edge<I,E> edge) throws IOException
sourceVertexId
- Source vertex id.edge
- Edge to be added.IOException
void removeEdgesRequest(I vertexIndex, I destinationVertexIndex) throws IOException
vertexIndex
- Index of the vertex to get the requestdestinationVertexIndex
- Index of the edge to be removedIOException
void addVertexRequest(Vertex<I,V,E> vertex) throws IOException
vertex
- Vertex to be addedIOException
void removeVertexRequest(I vertexIndex) throws IOException
vertexIndex
- Index of the vertex to be removedIOException
void flush() throws IOException
IOException
long resetMessageCount()
long resetMessageBytesCount()
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.