org.apache.giraph.comm.requests

Class ByteArrayRequest

java.lang.Object

org.apache.giraph.comm.requests.WritableRequest

org.apache.giraph.comm.requests.ByteArrayRequest

All Implemented Interfaces:

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

Direct Known Subclasses:

ByteArrayWithSenderTaskIdRequest, SendReducedToMasterRequest

public abstract class ByteArrayRequest
extends WritableRequest

Abstract request which has a byte array as its data

Field Summary

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

conf, UNKNOWN_SIZE

Method Summary

Modifier and Type	Method and Description
byte[]	getData() Get request data
DataInput	getDataInput() Get request data in the form of DataInput
int	getSerializedSize() Get the size of the request in serialized form.
UnsafeByteArrayInputStream	getUnsafeByteArrayInput() Wraps the byte array with UnsafeByteArrayInputStream stream.

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

Method Detail

getData

public byte[] getData()

Get request data

Returns:

Request data

getDataInput

public DataInput getDataInput()

Get request data in the form of DataInput

Returns:

Request data as DataInput

getUnsafeByteArrayInput

public UnsafeByteArrayInputStream getUnsafeByteArrayInput()

Wraps the byte array with UnsafeByteArrayInputStream stream.

Returns:

UnsafeByteArrayInputStream

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

Returns:

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