org.apache.giraph.comm.requests

Class SendVertexRequest<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.SendVertexRequest<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 SendVertexRequest<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 vertices for a partition. Note that this doesn't use a cache - might want to optimize in the future.

Field Summary

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

conf, UNKNOWN_SIZE

Constructor Summary

Constructors

Constructor and Description
SendVertexRequest() Constructor used for reflection only
SendVertexRequest(Partition<I,V,E> partition) Constructor for sending a 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

SendVertexRequest

public SendVertexRequest()

Constructor used for reflection only

SendVertexRequest

public SendVertexRequest(Partition<I,V,E> partition)

Constructor for sending a request.

Parameters:

partition - Partition to send the request to

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.