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

Class GidLongWritableRequest

java.lang.Object

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

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

All Implemented Interfaces:

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

public class GidLongWritableRequest
extends WritableRequest

Field Summary

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

conf, UNKNOWN_SIZE

Constructor Summary

Constructors

Constructor	Description
GidLongWritableRequest()
GidLongWritableRequest(long gid, org.apache.hadoop.io.LongWritable writable)

Method Summary

Modifier and Type	Method	Description
void	doRequest(MessageStore messageStore)	Apply this request on this message storage.
io.netty.buffer.ByteBuf	getBuffer()
long	getGid()
int	getNumBytes()	Should only return number of bytes in child class.
RequestType	getRequestType()	Serialization of request type is taken care by encoder.
long	getValue()
org.apache.hadoop.io.LongWritable	getWritable()
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

GidLongWritableRequest

public GidLongWritableRequest()

GidLongWritableRequest

public GidLongWritableRequest(long gid,
                              org.apache.hadoop.io.LongWritable writable)

Method Detail

getGid

public long getGid()

getWritable

public org.apache.hadoop.io.LongWritable getWritable()

getValue

public long getValue()

getRequestType

public RequestType getRequestType()

Description copied from class: WritableRequest

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()

Should only return number of bytes in child class.

Specified by:

getNumBytes in class WritableRequest

Returns:

number of bytes

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