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

Class WritableRequest<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

java.lang.Object

com.alibaba.graphscope.parallel.netty.request.WritableRequest<I,V,E>

All Implemented Interfaces:

org.apache.giraph.conf.GiraphConfigurationSettable<I,V,E>, org.apache.giraph.conf.ImmutableClassesGiraphConfigurable<I,V,E>, org.apache.hadoop.io.Writable

Direct Known Subclasses:

BatchWritableRequest, ByteBufRequest, GidLongWritableRequest, OneLongWritableRequest

public abstract class WritableRequest<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
extends Object
implements org.apache.hadoop.io.Writable, org.apache.giraph.conf.ImmutableClassesGiraphConfigurable<I,V,E>

Field Summary

Fields

Modifier and Type	Field	Description
protected ImmutableClassesGiraphConfiguration<I,V,E>	conf	Configuration
static int	UNKNOWN_SIZE

Constructor Summary

Constructors

Constructor	Description
WritableRequest()

Method Summary

Modifier and Type	Method	Description
abstract void	doRequest(MessageStore<I,org.apache.hadoop.io.Writable,?> messageStore)	Apply this request on this message storage.
abstract io.netty.buffer.ByteBuf	getBuffer()
ImmutableClassesGiraphConfiguration<I,V,E>	getConf()
abstract int	getNumBytes()
abstract RequestType	getRequestType()	Serialization of request type is taken care by encoder.
void	readFields(DataInput input)
abstract void	readFieldsRequest(DataInput input)
abstract void	setBuffer(io.netty.buffer.ByteBuf buf)
void	setConf(ImmutableClassesGiraphConfiguration<I,V,E> conf)
void	write(DataOutput output)
abstract void	writeFieldsRequest(DataOutput output)

Methods inherited from class java.lang.Object

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

Field Detail

UNKNOWN_SIZE

public static final int UNKNOWN_SIZE

See Also:

Constant Field Values

conf

protected ImmutableClassesGiraphConfiguration<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> conf

Configuration

Constructor Detail

WritableRequest

public WritableRequest()

Method Detail

getRequestType

public abstract RequestType getRequestType()

Serialization of request type is taken care by encoder.

Returns:

request type.

readFieldsRequest

public abstract void readFieldsRequest(DataInput input)
                                throws IOException

Throws:

IOException

writeFieldsRequest

public abstract void writeFieldsRequest(DataOutput output)
                                 throws IOException

Throws:

IOException

getNumBytes

public abstract int getNumBytes()

doRequest

public abstract void doRequest(MessageStore<I,org.apache.hadoop.io.Writable,?> messageStore)

Apply this request on this message storage.

Parameters:

messageStore - message store.

readFields

public final void readFields(DataInput input)
                      throws IOException

Specified by:

readFields in interface org.apache.hadoop.io.Writable

Throws:

IOException

write

public final void write(DataOutput output)
                 throws IOException

Specified by:

write in interface org.apache.hadoop.io.Writable

Throws:

IOException

getBuffer

public abstract io.netty.buffer.ByteBuf getBuffer()

setBuffer

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

Parameters:

buf -

getConf

public final ImmutableClassesGiraphConfiguration<I,V,E> getConf()

Specified by:

getConf in interface org.apache.giraph.conf.ImmutableClassesGiraphConfigurable<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

setConf

public final void setConf(ImmutableClassesGiraphConfiguration<I,V,E> conf)

Specified by:

setConf in interface org.apache.giraph.conf.GiraphConfigurationSettable<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>