org.apache.giraph.comm.requests

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

java.lang.Object

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

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

Type Parameters:

I - Vertex id

V - Vertex data

E - Edge data

All Implemented Interfaces:

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

public class SendPartitionMutationsRequest<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
extends WritableRequest<I,V,E>
implements WorkerRequest<I,V,E>

Send a collection of vertex mutations for a partition. This type of request is used for two purposes: 1) sending mutation requests generated due to user compute function in the middle of the execution of a superstep, and 2) sending mutation requests due to partition migration.

Field Summary

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

conf, UNKNOWN_SIZE

Constructor Summary

Constructors

Constructor and Description
SendPartitionMutationsRequest() Constructor used for reflection only
SendPartitionMutationsRequest(int partitionId, Map<I,VertexMutations<I,V,E>> vertexIdMutations) 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

SendPartitionMutationsRequest

public SendPartitionMutationsRequest()

Constructor used for reflection only

SendPartitionMutationsRequest

public SendPartitionMutationsRequest(int partitionId,
                                     Map<I,VertexMutations<I,V,E>> vertexIdMutations)

Constructor used to send request.

Parameters:

partitionId - Partition to send the request to

vertexIdMutations - Map of mutations to send

Method Detail

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

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

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.