org.apache.giraph.comm.requests

Class SendWorkerDataRequest<I extends org.apache.hadoop.io.WritableComparable,T,B extends VertexIdData<I,T>>

java.lang.Object

org.apache.giraph.comm.requests.WritableRequest

org.apache.giraph.comm.requests.SendWorkerDataRequest<I,T,B>

Type Parameters:

I - Vertex id

T - Data

B - Specialization of VertexIdData for T

All Implemented Interfaces:

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

Direct Known Subclasses:

SendWorkerEdgesRequest, SendWorkerMessagesRequest

public abstract class SendWorkerDataRequest<I extends org.apache.hadoop.io.WritableComparable,T,B extends VertexIdData<I,T>>
extends WritableRequest
implements WorkerRequest

Abstract request to send a collection of data, indexed by vertex id, for a partition.

Field Summary

Fields

Modifier and Type	Field and Description
protected PairList<Integer,B>	partitionVertexData All data for a group of vertices, organized by partition, which are owned by a single (destination) worker.

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

conf, UNKNOWN_SIZE

Constructor Summary

Constructors

Constructor and Description
SendWorkerDataRequest() Constructor used for reflection only
SendWorkerDataRequest(PairList<Integer,B> partVertData) Constructor used to send request.

Method Summary

Modifier and Type	Method and Description
abstract B	createVertexIdData() Create a new VertexIdData specialized for the use case.
int	getSerializedSize() Get the size of the request in serialized form.
void	readFieldsRequest(DataInput input) Serialize the request
void	writeRequest(DataOutput output) Deserialize the request

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

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.giraph.comm.requests.WorkerRequest

doRequest

Field Detail

partitionVertexData

protected PairList<Integer,B extends VertexIdData<I,T>> partitionVertexData

All data for a group of vertices, organized by partition, which are owned by a single (destination) worker. This data is all destined for this worker.

Constructor Detail

SendWorkerDataRequest

public SendWorkerDataRequest()

Constructor used for reflection only

SendWorkerDataRequest

public SendWorkerDataRequest(PairList<Integer,B> partVertData)

Constructor used to send request.

Parameters:

partVertData - Map of remote partitions => VertexIdData

Method Detail

createVertexIdData

public abstract B createVertexIdData()

Create a new VertexIdData specialized for the use case.

Returns:

A new instance of VertexIdData

readFieldsRequest

public void readFieldsRequest(DataInput input)
                       throws IOException

Description copied from class: WritableRequest

Serialize the request

Parameters:

input - Input to read fields from

Throws:

IOException

writeRequest

public void writeRequest(DataOutput output)
                  throws IOException

Description copied from class: WritableRequest

Deserialize the request

Parameters:

output - Output to write the request to

Throws:

IOException

getSerializedSize

public int getSerializedSize()

Description copied from class: WritableRequest

Get the size of the request in serialized form. The number returned by this function can't be less than the actual size - if the size can't be calculated correctly return WritableRequest.UNKNOWN_SIZE.

Overrides:

getSerializedSize in class WritableRequest

Returns:

The size (in bytes) of serialized request, or WritableRequest.UNKNOWN_SIZE if the size is not known or too expensive to calculate.