org.apache.giraph.comm.requests

Class SendWorkerToWorkerMessageRequest

java.lang.Object

org.apache.giraph.comm.requests.WritableRequest

org.apache.giraph.comm.requests.SendWorkerToWorkerMessageRequest

All Implemented Interfaces:

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

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

Request which sends any Writable message from one worker to another

Field Summary

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

conf, UNKNOWN_SIZE

Constructor Summary

Constructors

Constructor and Description
SendWorkerToWorkerMessageRequest() Default constructor, for reflection
SendWorkerToWorkerMessageRequest(org.apache.hadoop.io.Writable message) Constructor with message

Method Summary

Modifier and Type	Method and Description
void	doRequest(ServerData<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable> serverData) Execute the request
RequestType	getType() Get the type of the request

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

getClientId, getConf, getRequestId, getSerializedSize, 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

SendWorkerToWorkerMessageRequest

public SendWorkerToWorkerMessageRequest()

Default constructor, for reflection

SendWorkerToWorkerMessageRequest

public SendWorkerToWorkerMessageRequest(org.apache.hadoop.io.Writable message)

Constructor with message

Parameters:

message - Message sent

Method Detail

getType

public RequestType getType()

Description copied from class: WritableRequest

Get the type of the request

Specified by:

getType in class WritableRequest

Returns:

Request type

doRequest

public void doRequest(ServerData<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable> serverData)

Description copied from interface: WorkerRequest

Execute the request

Specified by:

doRequest in interface WorkerRequest<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