org.apache.giraph.comm.requests

Class SendWorkerOneMessageToManyRequest<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>

java.lang.Object

org.apache.giraph.comm.requests.WritableRequest<I,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>

org.apache.giraph.comm.requests.SendWorkerOneMessageToManyRequest<I,M>

Type Parameters:

I - Vertex id

M - Message data

All Implemented Interfaces:

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

public class SendWorkerOneMessageToManyRequest<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>
extends WritableRequest<I,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>
implements WorkerRequest<I,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>

Send a collection of ByteArrayOneMessageToManyIds messages to a worker.

Field Summary

Fields

Modifier and Type	Field and Description
protected ByteArrayOneMessageToManyIds<I,M>	oneMessageToManyIds ByteArrayOneMessageToManyIds encoding of vertexId & messages

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

conf, UNKNOWN_SIZE

Constructor Summary

Constructors

Constructor and Description
SendWorkerOneMessageToManyRequest() Constructor used for reflection only.
SendWorkerOneMessageToManyRequest(ByteArrayOneMessageToManyIds<I,M> oneMessageToManyIds, ImmutableClassesGiraphConfiguration conf) Constructor used to send request.

Method Summary

Modifier and Type	Method and Description
void	doRequest(ServerData 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

Field Detail

oneMessageToManyIds

protected ByteArrayOneMessageToManyIds<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable> oneMessageToManyIds

ByteArrayOneMessageToManyIds encoding of vertexId & messages

Constructor Detail

SendWorkerOneMessageToManyRequest

public SendWorkerOneMessageToManyRequest()

Constructor used for reflection only.

SendWorkerOneMessageToManyRequest

public SendWorkerOneMessageToManyRequest(ByteArrayOneMessageToManyIds<I,M> oneMessageToManyIds,
                                         ImmutableClassesGiraphConfiguration conf)

Constructor used to send request.

Parameters:

oneMessageToManyIds - ByteArrayOneMessageToManyIds

conf - ImmutableClassesGiraphConfiguration

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,org.apache.hadoop.io.Writable,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

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,org.apache.hadoop.io.Writable,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.

doRequest

public void doRequest(ServerData serverData)

Description copied from interface: WorkerRequest

Execute the request

Specified by:

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

Parameters:

serverData - Accessible data that can be mutated per the request