org.apache.giraph.comm.requests

Class SendAggregatorsToOwnerRequest

java.lang.Object

org.apache.giraph.comm.requests.WritableRequest

org.apache.giraph.comm.requests.ByteArrayRequest

org.apache.giraph.comm.requests.ByteArrayWithSenderTaskIdRequest

org.apache.giraph.comm.requests.SendAggregatorsToOwnerRequest

All Implemented Interfaces:

WorkerRequest, GiraphConfigurationSettable, ImmutableClassesGiraphConfigurable, org.apache.hadoop.io.Writable

public class SendAggregatorsToOwnerRequest
extends ByteArrayWithSenderTaskIdRequest
implements WorkerRequest

Request to send final aggregatd values from master to worker which owns the aggregators

Field Summary

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

conf, UNKNOWN_SIZE

Constructor Summary

Constructors

Constructor and Description
SendAggregatorsToOwnerRequest() Constructor used for reflection only
SendAggregatorsToOwnerRequest(byte[] data, int senderTaskId) Constructor

Method Summary

Modifier and Type	Method and Description
void	doRequest(ServerData serverData) Execute the request
RequestType	getType() Get the type of the request

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

getSenderTaskId, getSerializedSize

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

getData, getDataInput, getUnsafeByteArrayInput

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

SendAggregatorsToOwnerRequest

public SendAggregatorsToOwnerRequest(byte[] data,
                                     int senderTaskId)

Constructor

Parameters:

data - Serialized aggregator data

senderTaskId - Sender task id

SendAggregatorsToOwnerRequest

public SendAggregatorsToOwnerRequest()

Constructor used for reflection only

Method Detail

doRequest

public void doRequest(ServerData serverData)

Description copied from interface: WorkerRequest

Execute the request

Specified by:

doRequest in interface WorkerRequest

Parameters:

serverData - Accessible data that can be mutated per the request

getType

public RequestType getType()

Description copied from class: WritableRequest

Get the type of the request

Specified by:

getType in class WritableRequest

Returns:

Request type