Package com.alibaba.graphscope.parallel.netty.request.impl

Class ByteBufRequest

java.lang.Object

com.alibaba.graphscope.parallel.netty.request.WritableRequest

com.alibaba.graphscope.parallel.netty.request.impl.ByteBufRequest

All Implemented Interfaces:

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

public class ByteBufRequest
extends WritableRequest

A special type of request which store byteBuf as store.

Field Summary

Fields inherited from class com.alibaba.graphscope.parallel.netty.request.WritableRequest

conf, UNKNOWN_SIZE

Constructor Summary

Constructors

Constructor	Description
ByteBufRequest()	Default constructor for reflection usage.
ByteBufRequest(io.netty.buffer.ByteBuf in)

Method Summary

Modifier and Type	Method	Description
void	doRequest(MessageStore messageStore)	Apply this request on this message storage.
io.netty.buffer.ByteBuf	getBuffer()
int	getNumBytes()
RequestType	getRequestType()	Serialization of request type is taken care by encoder.
void	readFieldsRequest(DataInput input)
void	setBuffer(io.netty.buffer.ByteBuf buf)
String	toString()
void	writeFieldsRequest(DataOutput output)

Methods inherited from class com.alibaba.graphscope.parallel.netty.request.WritableRequest

getConf, readFields, setConf, write

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ByteBufRequest

public ByteBufRequest(io.netty.buffer.ByteBuf in)

ByteBufRequest

public ByteBufRequest()

Default constructor for reflection usage. SetBuffer should be called after construction.

Method Detail

getRequestType

public RequestType getRequestType()

Serialization of request type is taken care by encoder.

Specified by:

getRequestType in class WritableRequest

Returns:

request type.

readFieldsRequest

public void readFieldsRequest(DataInput input)
                       throws IOException

Specified by:

readFieldsRequest in class WritableRequest

Throws:

IOException

writeFieldsRequest

public void writeFieldsRequest(DataOutput output)
                        throws IOException

Specified by:

writeFieldsRequest in class WritableRequest

Throws:

IOException

getNumBytes

public int getNumBytes()

Specified by:

getNumBytes in class WritableRequest

getBuffer

public io.netty.buffer.ByteBuf getBuffer()

Specified by:

getBuffer in class WritableRequest

setBuffer

public void setBuffer(io.netty.buffer.ByteBuf buf)

Specified by:

setBuffer in class WritableRequest

Parameters:

buf -

doRequest

public void doRequest(MessageStore messageStore)

Apply this request on this message storage.

Specified by:

doRequest in class WritableRequest

Parameters:

messageStore - message store.

toString

public String toString()

Overrides:

toString in class Object