org.apache.giraph.comm.requests

Class SendPartitionCurrentMessagesRequest<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>

java.lang.Object

org.apache.giraph.comm.requests.WritableRequest<I,V,E>

org.apache.giraph.comm.requests.SendPartitionCurrentMessagesRequest<I,V,E,M>

Type Parameters:

I - Vertex id

V - Vertex data

E - Edge data

M - Message data

All Implemented Interfaces:

WorkerRequest<I,V,E>, GiraphConfigurationSettable<I,V,E>, ImmutableClassesGiraphConfigurable<I,V,E>, org.apache.hadoop.io.Writable

public class SendPartitionCurrentMessagesRequest<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 WritableRequest<I,V,E>
implements WorkerRequest<I,V,E>

Send a collection of vertex messages for a partition. It adds messages to current message store and it should be used only during partition exchange.

Field Summary

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

conf, UNKNOWN_SIZE

Constructor Summary

Constructors

Constructor and Description
SendPartitionCurrentMessagesRequest() Constructor used for reflection only
SendPartitionCurrentMessagesRequest(int partitionId, ByteArrayVertexIdMessages<I,M> vertexIdMessages) Constructor used to send request.

Method Summary

Modifier and Type	Method and Description
void	doRequest(ServerData<I,V,E> serverData) Execute the request
int	getSerializedSize() Get the size of the request in serialized form.
RequestType	getType() Get the type of the request
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, 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

SendPartitionCurrentMessagesRequest

public SendPartitionCurrentMessagesRequest()

Constructor used for reflection only

SendPartitionCurrentMessagesRequest

public SendPartitionCurrentMessagesRequest(int partitionId,
                                           ByteArrayVertexIdMessages<I,M> vertexIdMessages)

Constructor used to send request.

Parameters:

partitionId - Partition to send the request to

vertexIdMessages - Map of messages to send

Method Detail

getType

public RequestType getType()

Description copied from class: WritableRequest

Get the type of the request

Specified by:

getType in class WritableRequest<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

Returns:

Request type

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

doRequest

public void doRequest(ServerData<I,V,E> serverData)

Description copied from interface: WorkerRequest

Execute the request

Specified by:

doRequest in interface WorkerRequest<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

Parameters:

serverData - Accessible data that can be mutated per the request

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<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

Returns:

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