org.apache.giraph.comm.requests

Class SendWorkerEdgesRequest<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>

java.lang.Object

org.apache.giraph.comm.requests.WritableRequest

org.apache.giraph.comm.requests.SendWorkerDataRequest<I,Edge<I,E>,VertexIdEdges<I,E>>

org.apache.giraph.comm.requests.SendWorkerEdgesRequest<I,E>

Type Parameters:

I - Vertex id

E - Edge data

All Implemented Interfaces:

WorkerRequest, GiraphConfigurationSettable, ImmutableClassesGiraphConfigurable, org.apache.hadoop.io.Writable

public class SendWorkerEdgesRequest<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>
extends SendWorkerDataRequest<I,Edge<I,E>,VertexIdEdges<I,E>>

Send a collection of edges for a partition.

Field Summary

Fields inherited from class org.apache.giraph.comm.requests.SendWorkerDataRequest

partitionVertexData

Fields inherited from class org.apache.giraph.comm.requests.WritableRequest

conf, UNKNOWN_SIZE

Constructor Summary

Constructors

Constructor and Description
SendWorkerEdgesRequest() Constructor used for reflection only
SendWorkerEdgesRequest(PairList<Integer,VertexIdEdges<I,E>> partVertEdges) Constructor used to send request.

Method Summary

Modifier and Type	Method and Description
VertexIdEdges<I,E>	createVertexIdData() Create a new VertexIdData specialized for the use case.
void	doRequest(ServerData serverData) Execute the request
RequestType	getType() Get the type of the request

Methods inherited from class org.apache.giraph.comm.requests.SendWorkerDataRequest

getSerializedSize, readFieldsRequest, writeRequest

Methods inherited from class org.apache.giraph.comm.requests.WritableRequest

getClientId, getConf, getRequestId, readFields, setClientId, setConf, setRequestId, write

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SendWorkerEdgesRequest

public SendWorkerEdgesRequest()

Constructor used for reflection only

SendWorkerEdgesRequest

public SendWorkerEdgesRequest(PairList<Integer,VertexIdEdges<I,E>> partVertEdges)

Constructor used to send request.

Parameters:

partVertEdges - Map of remote partitions => ByteArrayVertexIdEdges

Method Detail

createVertexIdData

public VertexIdEdges<I,E> createVertexIdData()

Description copied from class: SendWorkerDataRequest

Create a new VertexIdData specialized for the use case.

Specified by:

createVertexIdData in class SendWorkerDataRequest<I extends org.apache.hadoop.io.WritableComparable,Edge<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>,VertexIdEdges<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>>

Returns:

A new instance of VertexIdData

getType

public RequestType getType()

Description copied from class: WritableRequest

Get the type of the request

Specified by:

getType in class WritableRequest

Returns:

Request type

doRequest

public void doRequest(ServerData serverData)

Description copied from interface: WorkerRequest

Execute the request

Parameters:

serverData - Accessible data that can be mutated per the request