org.apache.giraph.comm.requests

Class ByteArrayWithSenderTaskIdRequest

java.lang.Object

org.apache.giraph.comm.requests.WritableRequest

org.apache.giraph.comm.requests.ByteArrayRequest

org.apache.giraph.comm.requests.ByteArrayWithSenderTaskIdRequest

All Implemented Interfaces:

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

Direct Known Subclasses:

SendAggregatorsToOwnerRequest, SendAggregatorsToWorkerRequest, SendWorkerAggregatorsRequest

public abstract class ByteArrayWithSenderTaskIdRequest
extends ByteArrayRequest

Abstract request which has a byte array and task id of the sender as its data

Field Summary

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

conf, UNKNOWN_SIZE

Constructor Summary

Constructors

Constructor and Description
ByteArrayWithSenderTaskIdRequest() Default constructor
ByteArrayWithSenderTaskIdRequest(byte[] data, int senderTaskId) Constructor

Method Summary

Modifier and Type	Method and Description
int	getSenderTaskId()
int	getSerializedSize() Get the size of the request in serialized form.

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, getType, 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

ByteArrayWithSenderTaskIdRequest

public ByteArrayWithSenderTaskIdRequest(byte[] data,
                                        int senderTaskId)

Constructor

Parameters:

data - Request data

senderTaskId - Sender task id

ByteArrayWithSenderTaskIdRequest

public ByteArrayWithSenderTaskIdRequest()

Default constructor

Method Detail

getSenderTaskId

public int getSenderTaskId()

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 ByteArrayRequest

Returns:

The size (in bytes) of serialized request, or WritableRequest.UNKNOWN_SIZE if the size is not known or too expensive to calculate.