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

Class OneLongWritableRequest

java.lang.Object

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

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

All Implemented Interfaces:

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

public class OneLongWritableRequest
extends WritableRequest

Field Summary

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

conf, UNKNOWN_SIZE

Constructor Summary

Constructors

Constructor	Description
OneLongWritableRequest()

Method Summary

Modifier and Type	Method	Description
void	doRequest(MessageStore messageStore)	Apply this request on this message storage.
io.netty.buffer.ByteBuf	getBuffer()
org.apache.hadoop.io.LongWritable	getData()
int	getNumBytes()
long	getRawValue()
RequestType	getRequestType()	Serialization of request type is taken care by encoder.
void	readFieldsRequest(DataInput input)
void	setBuffer(io.netty.buffer.ByteBuf buf)
void	setData(org.apache.hadoop.io.LongWritable value)
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, toString, wait, wait, wait

Constructor Detail

OneLongWritableRequest

public OneLongWritableRequest()

Method Detail

getData

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

setData

public void setData(org.apache.hadoop.io.LongWritable value)

getRawValue

public long getRawValue()

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

Specified by:

getNumBytes in class WritableRequest

doRequest

public void doRequest(MessageStore messageStore)

Apply this request on this message storage.

Specified by:

doRequest in class WritableRequest

Parameters:

messageStore - message store.

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 -